Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 364EF200C2C for ; Fri, 3 Mar 2017 11:35:50 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 34E3A160B6D; Fri, 3 Mar 2017 10:35:50 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 7E03A160B57 for ; Fri, 3 Mar 2017 11:35:49 +0100 (CET) Received: (qmail 23938 invoked by uid 500); 3 Mar 2017 10:35:48 -0000 Mailing-List: contact dev-help@apex.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.apache.org Delivered-To: mailing list dev@apex.apache.org Received: (qmail 23925 invoked by uid 99); 3 Mar 2017 10:35:48 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 03 Mar 2017 10:35:48 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 3A7E818E86E for ; Fri, 3 Mar 2017 10:35:48 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -2.347 X-Spam-Level: X-Spam-Status: No, score=-2.347 tagged_above=-999 required=6.31 tests=[RP_MATCHES_RCVD=-2.999, SPF_NEUTRAL=0.652] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id Fu5s93IGd5dx for ; Fri, 3 Mar 2017 10:35:47 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id 3EBF65FBC1 for ; Fri, 3 Mar 2017 10:35:47 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 93AD7E04A6 for ; Fri, 3 Mar 2017 10:35:46 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id B56EE2415C for ; Fri, 3 Mar 2017 10:35:45 +0000 (UTC) Date: Fri, 3 Mar 2017 10:35:45 +0000 (UTC) From: "Tushar Gosavi (JIRA)" To: dev@apex.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Assigned] (APEXCORE-580) Interface for processing and emitting control tuples MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 03 Mar 2017 10:35:50 -0000 [ https://issues.apache.org/jira/browse/APEXCORE-580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tushar Gosavi reassigned APEXCORE-580: -------------------------------------- Assignee: Bhupesh Chawda > 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 (v6.3.15#6346)