[
https://issues.apache.org/jira/browse/APEXCORE-580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan updated APEXCORE-580:
-------------------------------
Description:
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.
was:
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.
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 tp easily change that
behavior. The user can selectively propagate control tuples to certain output
ports, or block the propagation altogether.
> 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.4#6332)
