Return-Path: <issues-return-83292-archive-asf-public=cust-asf.ponee.io@flink.apache.org>
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 19CE3200BE5
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Sat, 10 Dec 2016 02:52:00 +0100 (CET)
Received: by cust-asf.ponee.io (Postfix)
	id 171BB160B2A; Sat, 10 Dec 2016 01:52:00 +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 6A138160B1D
	for <archive-asf-public@cust-asf.ponee.io>; Sat, 10 Dec 2016 02:51:59 +0100 (CET)
Received: (qmail 44121 invoked by uid 500); 10 Dec 2016 01:51:58 -0000
Mailing-List: contact issues-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:issues-help@flink.apache.org>
List-Unsubscribe: <mailto:issues-unsubscribe@flink.apache.org>
List-Post: <mailto:issues@flink.apache.org>
List-Id: <issues.flink.apache.org>
Reply-To: dev@flink.apache.org
Delivered-To: mailing list issues@flink.apache.org
Received: (qmail 44107 invoked by uid 99); 10 Dec 2016 01:51:58 -0000
Received: from arcas.apache.org (HELO arcas) (140.211.11.28)
    by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 10 Dec 2016 01:51:58 +0000
Received: from arcas.apache.org (localhost [127.0.0.1])
	by arcas (Postfix) with ESMTP id 81DFC2C03DE
	for <issues@flink.apache.org>; Sat, 10 Dec 2016 01:51:58 +0000 (UTC)
Date: Sat, 10 Dec 2016 01:51:58 +0000 (UTC)
From: "ASF GitHub Bot (JIRA)" <jira@apache.org>
To: issues@flink.apache.org
Message-ID: <JIRA.12999324.1471976876000.489249.1481334718528@Atlassian.JIRA>
In-Reply-To: <JIRA.12999324.1471976876000@Atlassian.JIRA>
References: <JIRA.12999324.1471976876000@Atlassian.JIRA> <JIRA.12999324.1471976876649@arcas>
Subject: [jira] [Commented] (FLINK-4460) Side Outputs in Flink
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394
archived-at: Sat, 10 Dec 2016 01:52:00 -0000


    [ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15736976#comment-15736976 ] 

ASF GitHub Bot commented on FLINK-4460:
---------------------------------------

GitHub user chenqin opened a pull request:

    https://github.com/apache/flink/pull/2982

    [FLINK-4460] Side Outputs in Flink

    [FLIP-13](https://cwiki.apache.org/confluence/display/FLINK/FLIP-13+Side+Outputs+in+Flink) Expose sideOutput with `OutputTag<T>`, 
    
    For those userFunction provide `Collector<OUT> collector` as a parameter, 
     - it offer a util class`CollectorWrapper<OUT> wrapper = new CollectorWrapper<OUT>(collector);` which can write sideOutput element `wrapper.collect(OutputTag<SIDEOUT> tag, sideout)` as well as `getSideOutput(OutputTag<SIDEOUT> tag)` in `singleStreamOutputOpeator` and get sideOutput DataStream<SIDEOUT>.
     - each OutputTag with same type can have different value, getSideOutput will only expose element with exact same OutputTag type and value. 
    
    sideOutput Late arriving event if
    - time characteristic set to eventTime
    - all assigned window(s) isLate return(s) true 
    - event timestamp no later than currentWatermark+ allowedLateness)

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/chenqin/flink flip

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/2982.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2982
    
----
commit de674f19fcbe9955cb4208ef0938fe5b0f7adc90
Author: Chen Qin <qinnchen@fgmail.com>
Date:   2016-10-21T19:38:04Z

    allow mutpile output stream

commit 3d91e6c69dbfbcb2c73dcc37ac2d8ed637a374eb
Author: Chen Qin <cq@uber.com>
Date:   2016-11-29T21:24:09Z

    Merge branch 'master' into flip

commit 977b2d7fc54e1f9663a5ceb8a62ed2af5a955ca6
Author: Chen Qin <cq@uber.com>
Date:   2016-12-01T22:19:56Z

    allow mutiple OutputTag with same type
    implement windowopeator late arriving events
    add unit/integration tests

----


> Side Outputs in Flink
> ---------------------
>
>                 Key: FLINK-4460
>                 URL: https://issues.apache.org/jira/browse/FLINK-4460
>             Project: Flink
>          Issue Type: New Feature
>          Components: Core, DataStream API
>    Affects Versions: 1.2.0, 1.1.3
>            Reporter: Chen Qin
>              Labels: latearrivingevents, sideoutput
>
> https://docs.google.com/document/d/1vg1gpR8JL4dM07Yu4NyerQhhVvBlde5qdqnuJv4LcV4/edit?usp=sharing



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)