flink-remote-shuffle icon indicating copy to clipboard operation
flink-remote-shuffle copied to clipboard

Published 20 hours ago • verified publisher icon flink-extended

[FRS-40] SortBuffer supports reading data from the specified channel index

Open TanYuxin-tyx opened this issue 2 years ago • 0 comments

What is the purpose of the change

SortBuffer can improve read performance significantly, but it doesn't support read data from a specific channel. The development of some new functions, for example, ReducePartition implementation, depends on the ability of SortBuffer to read data from the specified channel. This issue is to support the feature for SortBuffer.

Brief change log

  • SortBuffer supports reading data from the specified channel index.

Verifying this change

This change added tests.

TanYuxin-tyx avatar Mar 01 '22 03:03 TanYuxin-tyx