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.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.
|
org.apache.reef.wake.remote.transport |
Wake's remote transportation.
|
org.apache.reef.wake.remote.transport.netty |
Netty-based remote transport implementation.
|
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 | 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 |
MultiEncoder<T>
Encoder using the WakeTuple protocol buffer.
|
class |
ObjectSerializableCodec<T>
Codec that uses Java serialization.
|
class |
RemoteEventCodec<T>
Codec of the event sent remotely.
|
class |
RemoteEventEncoder<T>
Remote event encoder using the WakeMessage protocol buffer.
|
class |
StringCodec
Codec that encodes/decodes a string.
|
Constructor and Description |
---|
RemoteEventEncoder(Encoder<T> encoder)
Constructs a remote event encoder.
|
RemoteSenderStage(Encoder encoder,
Transport transport,
int numThreads)
Constructs a remote sender stage.
|
Constructor and Description |
---|
MultiEncoder(Map<Class<? extends T>,Encoder<? extends T>> clazzToEncoderMap)
Constructs an encoder that encodes an object to bytes based on the class name.
|
Modifier and Type | Method and Description |
---|---|
<T> Link<T> |
Transport.open(SocketAddress remoteAddr,
Encoder<? super T> encoder,
LinkListener<? super T> listener)
Returns a link for the remote address if cached; otherwise opens, caches and returns.
|
Modifier and Type | Class and Description |
---|---|
class |
ByteEncoder
Wrapping encoder for byte[].
|
Modifier and Type | Method and Description |
---|---|
<T> Link<T> |
NettyMessagingTransport.open(SocketAddress remoteAddr,
Encoder<? super T> encoder,
LinkListener<? super T> listener)
Returns a link for the remote address if cached; otherwise opens, caches and returns.
|
Constructor and Description |
---|
NettyLink(io.netty.channel.Channel channel,
Encoder<? super T> encoder)
Constructs a link.
|
NettyLink(io.netty.channel.Channel channel,
Encoder<? super T> encoder,
LinkListener<? super T> listener)
Constructs a link.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.