You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Rong Rong (JIRA)" <ji...@apache.org> on 2019/01/29 15:09:00 UTC

[jira] [Created] (FLINK-11453) Support SliceWindow with forwardable pane info

Rong Rong created FLINK-11453:
---------------------------------

             Summary: Support SliceWindow with forwardable pane  info
                 Key: FLINK-11453
                 URL: https://issues.apache.org/jira/browse/FLINK-11453
             Project: Flink
          Issue Type: Sub-task
          Components: DataStream API
            Reporter: Rong Rong


Support slicing operation that produces slicing:
{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)
{code}
{{SlicedStream}} will produce results that exposes current {{WindowOperator}} internal state {{InternalAppendingState<K, W, IN, ACC, ACC>}}, which can be later applied with {{WindowFunction}} separately in another operator.



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