Package | Description |
---|---|
org.apache.reef.examples.group.utils.math |
Math utilities for Group Communication.
|
org.apache.reef.examples.suspend |
Suspend/resume demo.
|
org.apache.reef.io.network |
TODO: Document.
|
org.apache.reef.io.network.group.impl |
Implementations for Elastic Group Communications.
|
org.apache.reef.io.network.impl |
TODO: Document.
|
org.apache.reef.io.network.naming.serialization |
Contains naming serialization codecs.
|
org.apache.reef.io.network.util |
Utility for REEF IO network module.
|
org.apache.reef.runtime.common.launch |
Common launch code between Driver and Evaluator.
|
org.apache.reef.runtime.mesos.util |
Utility for Mesos runtime.
|
org.apache.reef.wake.remote |
Wake's remote communication.
|
org.apache.reef.wake.remote.impl |
Implementations for Wake's remote communication.
|
Modifier and Type | Class and Description |
---|---|
class |
VectorCodec
Codec for the Vector type Uses Data*Stream.
|
Modifier and Type | Class and Description |
---|---|
class |
ObjectWritableCodec<T extends org.apache.hadoop.io.Writable>
Codec for Hadoop Writable object serialization.
|
Modifier and Type | Method and Description |
---|---|
<T> ConnectionFactory<T> |
NetworkConnectionService.registerConnectionFactory(Identifier connectionFactoryId,
Codec<T> codec,
EventHandler<Message<T>> eventHandler,
LinkListener<Message<T>> linkListener,
Identifier localEndPointId)
Registers an instance of ConnectionFactory corresponding to the connectionFactoryId.
|
Modifier and Type | Class and Description |
---|---|
class |
GroupCommunicationMessageCodec
Codec for
ReefNetworkGroupCommProtos.GroupCommMessage . |
Modifier and Type | Interface and Description |
---|---|
interface |
StreamingCodec<T>
A codec that can make serialization more efficient when an object has to be.
|
Modifier and Type | Class and Description |
---|---|
class |
NSMessageCodec<T>
Network service message codec.
|
Modifier and Type | Method and Description |
---|---|
Codec<T> |
NetworkService.getCodec() |
Modifier and Type | Method and Description |
---|---|
<T> ConnectionFactory<T> |
NetworkConnectionServiceImpl.registerConnectionFactory(Identifier connectionFactoryId,
Codec<T> codec,
EventHandler<Message<T>> eventHandler,
LinkListener<Message<T>> linkListener,
Identifier localEndPointId) |
Constructor and Description |
---|
NetworkService(IdentifierFactory factory,
int nsPort,
NameResolver nameResolver,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
NSMessageCodec(Codec<T> codec,
IdentifierFactory factory)
Constructs a network service message codec.
|
Modifier and Type | Class and Description |
---|---|
class |
NamingLookupRequestCodec
Naming lookup request codec.
|
class |
NamingLookupResponseCodec
Naming lookup response codec.
|
class |
NamingRegisterRequestCodec
Naming registration request codec.
|
class |
NamingRegisterResponseCodec
naming registration response codec.
|
class |
NamingUnregisterRequestCodec
Naming un-registration request codec.
|
Modifier and Type | Class and Description |
---|---|
class |
ListCodec<T> |
Constructor and Description |
---|
ListCodec(Codec<T> codec) |
Modifier and Type | Class and Description |
---|---|
class |
REEFMessageCodec
Codec for REEF's control flow messages.
|
Modifier and Type | Class and Description |
---|---|
class |
MesosRemoteManagerCodec
EvaluatorControl codec.
|
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.