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)