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.group.impl |
Implementations for Elastic Group Communications.
|
org.apache.reef.io.network.group.impl.utils |
Utilities for group communication.
|
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 | Class and Description |
---|---|
class |
GroupCommunicationMessageCodec
Codec for
ReefNetworkGroupCommProtos.GroupCommMessage . |
Modifier and Type | Class and Description |
---|---|
class |
ScatterDecoder
Decode messages that was created by
ScatterEncoder . |
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 | 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> |
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 | Interface and Description |
---|---|
interface |
Codec<T>
Interface for serialization routines that translate back and forth between
byte arrays with low latency.
|
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 |
MultiDecoder<T>
Decoder using the WakeTuple protocol buffer.
|
class |
ObjectSerializableCodec<T>
Codec that uses Java serialization.
|
class |
RemoteEventCodec<T>
Codec of the event sent remotely.
|
class |
RemoteEventDecoder<T>
Remote event decoder using the WakeMessage protocol buffer.
|
class |
StringCodec
Codec that encodes/decodes a string.
|
Constructor and Description |
---|
RemoteEventDecoder(Decoder<T> decoder)
Constructs a remote event decoder.
|
Constructor and Description |
---|
MultiDecoder(Map<Class<? extends T>,Decoder<? extends T>> clazzToDecoderMap)
Constructs a decoder that decodes bytes based on the class name.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.