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

[Shang Yuanchun (Jira)]

Rong Rong created FLINK-11454:
---------------------------------

             Summary: 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


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)