Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
User specified class to convert the message to be communicated in to pipelining amenable data and vice-versa More...
Inherited by Org.Apache.REEF.Network.Group.Pipelining.Impl.DefaultPipelineDataConverter< T >.
Public Member Functions | |
List< PipelineMessage< T > > | PipelineMessage (T message) |
Converts the original message to be communicated in to a vector of pipelined messages. More... | |
T | FullMessage (List< PipelineMessage< T >> pipelineMessage) |
Constructs the full final message from the vector of communicated pipelined messages More... | |
User specified class to convert the message to be communicated in to pipelining amenable data and vice-versa
T | The message type |
T Org.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< T >.FullMessage | ( | List< PipelineMessage< T >> | pipelineMessage | ) |
Constructs the full final message from the vector of communicated pipelined messages
pipelineMessage | The enumerator over received pipelined messages |
Implemented in Org.Apache.REEF.Network.Group.Pipelining.Impl.DefaultPipelineDataConverter< T >.
List<PipelineMessage<T> > Org.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< T >.PipelineMessage | ( | T | message | ) |
Converts the original message to be communicated in to a vector of pipelined messages.
Each element of vector is communicated as a single logical unit.
message | The original message |
Implemented in Org.Apache.REEF.Network.Group.Pipelining.Impl.DefaultPipelineDataConverter< T >.