...
In this FLIP, we propose two main enhancements. Firstly, we propose enabling DataStream to directly transform into a PartitionWindowedStream. The PartitionWindowedStream represents collecting all records of each subtask separately into a full window. Secondly, we propose supporting four APIs on PartitionWindowedStream, including mapPartition
, sortPartition
, aggregate
and reduce
.
Public Interfaces
1. We introduce the fullWindowPartition
method to the DataStream class.
...