[jira] [Created] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[Shang Yuanchun (Jira)]

Congxian Qiu(klion26) created FLINK-13148:
---------------------------------------------

             Summary: Expose WindowedStream.sideOutputLateData() from CoGroupedStreams
                 Key: FLINK-13148
                 URL: https://issues.apache.org/jira/browse/FLINK-13148
             Project: Flink
          Issue Type: Improvement
          Components: API / DataStream
            Reporter: Congxian Qiu(klion26)
            Assignee: Congxian Qiu(klion26)


As FLINK-10050 supported {{alloedLateness}}, but we can not get the side output containing the late data, this issue wants to fix it.

For implementation, I want to add an input parameter {{OutputTag}} in {{WithWindow}} as following
{code:java}
protected WithWindow(DataStream<T1> input1,
    DataStream<T2> input2,
    KeySelector<T1, KEY> keySelector1,
    KeySelector<T2, KEY> keySelector2,
    TypeInformation<KEY> keyType,
    WindowAssigner<? super TaggedUnion<T1, T2>, W> windowAssigner,
    Trigger<? super TaggedUnion<T1, T2>, ? super W> trigger,
    Evictor<? super TaggedUnion<T1, T2>, ? super W> evictor,
    Time allowedLateness,
    OutputTage<TaggedUnion<T1, T2>> outputTag) {
      ...
}
{code}
 and add a function sideOutputLateData(OutputTag<T> outputTag) in with Window
{code:java}
public WithWindow<T1, T2, KEY, W> sideOutputLateData(OutputTag<TaggedUnion<T1, T2>> outputTag) {
   ...
}
{code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)