|
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 >.
1.8.11