Rong Rong created FLINK-11456:
---------------------------------
Summary: 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
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)
