[ https://issues.apache.org/jira/browse/FLINK-11456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
vinoyang reassigned FLINK-11456: -------------------------------- Assignee: vinoyang > Improve window operator with sliding window assigners > ----------------------------------------------------- > > Key: FLINK-11456 > URL: https://issues.apache.org/jira/browse/FLINK-11456 > Project: Flink > Issue Type: Sub-task > Components: DataStream API > Reporter: Rong Rong > Assignee: vinoyang > Priority: Major > > With Slicing and merging operators that exposes the internals of window > operators. current sliding window can be improved by eliminating duplicate > aggregations or duplicate element insert into multiple panes (e.g. > namespaces). > The following sliding window operation > {code:java} > val resultStream: DataStream = inputStream > .keyBy("key") > .window(SlidingEventTimeWindow.of(Time.seconds(5L), Time.seconds(15L))) > .sum("value") > {code} > can produce job graph equivalent to > {code:java} > val resultStream: DataStream = inputStream > .keyBy("key") > .sliceWindow(Time.seconds(5L)) > .sum("value") > .slideOver(Count.of(3)) > {code} > -- This message was sent by Atlassian JIRA (v7.6.3#76005)