[jira] [Commented] (FLINK-11454) Support MergedStream operation

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

    [ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769779#comment-16769779 ] 

Rong Rong commented on FLINK-11454:
-----------------------------------

Initial thought was to use the {{[Proctime/Rowtime][Bounded/Unbounded]Over}} operator in TableAPI to implement this.

However, this will involve a migration from the TabelAPI to the DataStream API. Wasn't sure if this is worth some discussion first before I dive into the implementation. Any suggestions are welcome [~fhueske] [~aljoscha] 

> Support MergedStream operation
> ------------------------------
>
>                 Key: FLINK-11454
>                 URL: https://issues.apache.org/jira/browse/FLINK-11454
>             Project: Flink
>          Issue Type: Sub-task
>          Components: DataStream API
>            Reporter: Rong Rong
>            Assignee: Rong Rong
>            Priority: Major
>
> Following SlicedStream, the mergedStream operator merges results from sliced stream and produces windowing results.
> {code:java}
> val slicedStream: SlicedStream = inputStream
>   .keyBy("key")
>   .sliceWindow(Time.seconds(5L))       // new “slice window” concept: to combine 
>                                        // tumble results based on discrete
>                                        // non-overlapping windows.
>   .aggregate(aggFunc)
> val mergedStream1: MergedStream = slicedStream
>   .slideOver(Time.second(10L))         // combine slice results with same                
>                                        // windowing function, equivalent to 
>                                        // WindowOperator with an aggregate state 
>                                        // and derived aggregate function.
> val mergedStream2: MergedStream = slicedStream
>   .slideOver(Count.of(5))
>   .apply(windowFunction)               // apply a different window function over  
>                                        // the sliced results.{code}
> MergedStream are produced by MergeOperator. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)