[ https://issues.apache.org/jira/browse/APEXCORE-580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15877448#comment-15877448 ]
ASF GitHub Bot commented on APEXCORE-580: ----------------------------------------- Github user bhupeshchawda closed the pull request at: https://github.com/apache/apex-core/pull/440 > Interface for processing and emitting control tuples > ---------------------------------------------------- > > Key: APEXCORE-580 > URL: https://issues.apache.org/jira/browse/APEXCORE-580 > Project: Apache Apex Core > Issue Type: Sub-task > Reporter: David Yan > > DefaultOutputPort needs to have a emitControl method so that operator code > can call to emit a control tuple. > DefaultInputPort needs to have a processControl method so that operator would > be able to act on the arrival of a control tuple. > Similar to a regular data tuple, we also need to provide a way for the user > to provide custom serialization for the control tuple. > We need to design this so that the default behavior is to propagate control > tuples to all output ports, and it should allow the user to easily change > that behavior. The user can selectively propagate control tuples to certain > output ports, or block the propagation altogether. -- This message was sent by Atlassian JIRA (v6.3.15#6346)