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

["Rong Rong (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-11456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Rong Rong closed FLINK-11456.
-----------------------------
    Resolution: Invalid

> 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: API / DataStream
>            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)