[REEF-555] Introduce MapInputWithControlMessage

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.12
• Component/s: REEF.NET

Environment

C#

• Assignee: Dhruv Mahajan
• Reporter: Dhruv Mahajan
• Created: 03/Aug/15 23:03
• Updated: 06/Aug/15 22:39
• Resolved: 06/Aug/15 22:39

Description

The aim of this JIRA is to implement the following classes:

a) TMapInputWithControlMessage - include both input for mapper as well as the message of whether to continue or stop. Input will be present only if we want to continue.
b) TMapInputWithControlMessageCodec
TMapInputWithControlMessagePipelineDataConverter that uses PipelineConverter of TMapInput as the base converter.