[FLINK-11453] Support SliceStream with forwardable pane info

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Rong Rong
• Reporter: Rong Rong
• Created: 29/Jan/19 15:08
• Updated: 19/Sep/19 19:18
• Resolved: 02/Mar/19 17:47

Description

Support slicing operation that produces slicing:

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)

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.

Issue Links

• links to: GitHub Pull Request #7678