This project has retired. For details please refer to its Attic page.
Apache REEF: Org.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< T > Interface Template Reference
Apache REEF  0.15.0
Retainable Evaluator Execution Framework
Public Member Functions | List of all members
Org.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< T > Interface Template Reference

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...
 
FullMessage (List< PipelineMessage< T >> pipelineMessage)
 Constructs the full final message from the vector of communicated pipelined messages More...
 

Detailed Description

User specified class to convert the message to be communicated in to pipelining amenable data and vice-versa

Template Parameters
TThe message type

Member Function Documentation

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

Parameters
pipelineMessageThe enumerator over received pipelined messages
Returns
The full constructed message

Implemented in Org.Apache.REEF.Network.Group.Pipelining.Impl.DefaultPipelineDataConverter< T >.

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.

Parameters
messageThe original message
Returns
The list of pipelined messages

Implemented in Org.Apache.REEF.Network.Group.Pipelining.Impl.DefaultPipelineDataConverter< T >.


The documentation for this interface was generated from the following file: