Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Classes | |
class | MapInputWithControlMessage |
Input to Map task Containes both actual message of type TMapInput and control message from UpdateTask | |
class | MapInputWithControlMessageCodec |
Streaming codec for MapInputWithControlMessage | |
class | MapInputwithControlMessagePipelineDataConverter |
Pipeline Data Converter for MapInputwithControlMessage to chunk and dechunk the message for communication | |