An implementation of IPipelineDataConverter for pipelining Arrays of objects. More...
Inherits Org.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< T[]>.
Public Member Functions | |
| List< PipelineMessage< T[]> > | PipelineMessage (T[] message) |
| Converts the original message to be communicated in to multiple messages, breaking the array into pieces of size PipelineMessageSize More... | |
| T [] | FullMessage (List< PipelineMessage< T[]>> pipelineMessage) |
| Constructs the full final message from the communicated pipelined message More... | |
 Public Member Functions inherited from Org.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< T[]> | |
| 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... | |
Detailed Description
An implementation of IPipelineDataConverter for pipelining Arrays of objects.
- Template Parameters
-
T The type of object of the array to pipeline
- Type Constraints
-
T : new()
Member Function Documentation
◆ FullMessage()
|
inline |
Constructs the full final message from the communicated pipelined message
- Parameters
-
pipelineMessage A list of received pipelined messages
- Returns
- The full constructed message
◆ PipelineMessage()
|
inline |
Converts the original message to be communicated in to multiple messages, breaking the array into pieces of size PipelineMessageSize
- Parameters
-
message The original message
- Returns
- The list of pipelined messages
The documentation for this class was generated from the following file:
- lang/cs/Org.Apache.REEF.Network/Group/Pipelining/Impl/ArrayPipelineDataConverter.cs
