This project has retired. For details please refer to its Attic page.
Apache REEF: Org.Apache.REEF.IMRU.OnREEF.MapInputWithControlMessage Namespace Reference
Apache REEF  0.15.0
Retainable Evaluator Execution Framework
Classes
Org.Apache.REEF.IMRU.OnREEF.MapInputWithControlMessage Namespace Reference

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