Yingjie Cao created FLINK-19597:
-----------------------------------
Summary: Introduce SortBuffer and its implementation
PartitionSortedBuffer for sort-merge based blocking shuffle
Key: FLINK-19597
URL: https://issues.apache.org/jira/browse/FLINK-19597
Project: Flink
Issue Type: Sub-task
Components: Runtime / Network
Affects Versions: 1.12.0
Reporter: Yingjie Cao
Fix For: 1.12.0
Data of different channels can be appended to a SortBuffer and after the
SortBuffer is finished, the appended data can be copied from it in channel
index order. PartitionSortedBuffer is an implementation of SortBuffer and it
sorts all appended records only by subpartition index. Records of the same
subpartition keep the appended order.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
