I'm trying to get a list of late elements in my Tumbling Windows application
and I noticed
that I need to use SingleOutputStreamOperator<T> instead of DataStream<T> to
get
access to the .sideOutputLateData(...) method.
Can someone explain what the difference is between
SingleOutputStreamOperator and DataStream
and why I need to use this for getting the late data?
Thanks!
Snippet:
OutputTag<EventBean> lateEventsTag = new
OutputTag<EventBean>("late-events") {};
SingleOutputStreamOperator<EventBean> windowedEvents = eventStream
.keyBy("key")
.window(TumblingEventTimeWindows.of(Time.seconds(3)))
.sideOutputLateData(lateEventsTag)
.process(new EventBeanProcessWindowFunction());
DataStream<EventBean> lateEvents =
windowedEvents.getSideOutput(lateEventsTag);
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
