...
The return type of the fullWindowPartition()
method is PartitionWindowedStream
, which provides multiple APIs for full window processing, including mapPartition
, sortPartition
, aggregate
and reduce
.
For non-keyed datastream, the upstream operators must have a POINTWISE connection pattern with operators in PartitionWindowedStream
. PartitionWindowedStream
does not support customizing parallelism. Its parallelism is consistent with the previous operator.
...