Org.Apache.REEF.Network.Group.Pipelining.Impl.DefaultPipelineDataConverter< T > Class Template Reference

Default IPipelineDataConverter implementation This basically is a non-pipelined implementation that just packs the whole message in one single PipelineMessage More...

Inherits Org.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< T >.

Public Member Functions
	DefaultPipelineDataConverter ()
List< PipelineMessage< T > >	PipelineMessage (T message)
	Converts the original message to be communicated in to a single pipelined message More...
T	FullMessage (List< PipelineMessage< T >> pipelineMessage)
	Constructs the full final message from the communicated pipelined message More...

Detailed Description

Default IPipelineDataConverter implementation This basically is a non-pipelined implementation that just packs the whole message in one single PipelineMessage

Template Parameters

T	The message type

Constructor & Destructor Documentation

Org.Apache.REEF.Network.Group.Pipelining.Impl.DefaultPipelineDataConverter< T >.DefaultPipelineDataConverter ( )

inline

Member Function Documentation

T Org.Apache.REEF.Network.Group.Pipelining.Impl.DefaultPipelineDataConverter< T >.FullMessage ( List< PipelineMessage< T >>  pipelineMessage )

inline

Constructs the full final message from the communicated pipelined message

Parameters

pipelineMessage

The enumerator over received pipelined messages It is assumed to have only one element

Returns

The full constructed message

Implements Org.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< T >.

List<PipelineMessage<T> > Org.Apache.REEF.Network.Group.Pipelining.Impl.DefaultPipelineDataConverter< T >.PipelineMessage ( T  message )

inline

Converts the original message to be communicated in to a single pipelined message

Parameters

message

The original message

Returns

The list of pipelined messages with only one element

Implements Org.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< T >.

---

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

• lang/cs/Org.Apache.REEF.Network/Group/Pipelining/Impl/DefaultPipelineDataConverter.cs