apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tushar Gosavi (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (APEXCORE-580) Interface for processing and emitting control tuples
Date Fri, 03 Mar 2017 10:35:45 GMT

     [ https://issues.apache.org/jira/browse/APEXCORE-580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

Tushar Gosavi resolved APEXCORE-580.
       Resolution: Fixed
    Fix Version/s: 3.6.0

> 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
>            Assignee: Bhupesh Chawda
>             Fix For: 3.6.0
> 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

View raw message