| Package | Description |
|---|---|
| org.apache.reef.wake.remote |
Wake's remote communication.
|
| org.apache.reef.wake.remote.impl |
Implementations for Wake's remote communication.
|
| Modifier and Type | Method and Description |
|---|---|
<T> RemoteManager |
RemoteManagerFactory.getInstance(String name,
Codec<T> codec,
EventHandler<Throwable> errorHandler) |
<T> RemoteManager |
RemoteManagerFactory.getInstance(String name,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler) |
<T> RemoteManager |
RemoteManagerFactory.getInstance(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout)
The old constructor of DefaultRemoteManagerImplementation.
|
<T> RemoteManager |
RemoteManagerFactory.getInstance(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout,
LocalAddressProvider localAddressProvider,
TcpPortProvider tcpPortProvider)
The all-out constructor of DefaultRemoteManagerImplementation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ByteCodec
Codec that performs identity transformation on bytes.
|
class |
MultiCodec<T>
Codec using the WakeTuple protocol buffer.
|
class |
ObjectSerializableCodec<T>
Codec that uses Java serialization.
|
class |
RemoteEventCodec<T>
Codec of the event sent remotely.
|
class |
StringCodec
Codec that encodes/decodes a string.
|
| Constructor and Description |
|---|
RemoteEventCodec(Codec<T> codec)
Constructs a remote event codec.
|
| Constructor and Description |
|---|
MultiCodec(Map<Class<? extends T>,Codec<? extends T>> clazzToCodecMap)
Constructs a codec that encodes/decodes an object to/from bytes based on the class name.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.