[jira] [Created] (FLINK-11456) Improve window operator with sliding window assigners

[Shang Yuanchun (Jira)]

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)