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

Published 20 hours ago • verified publisher icon flink-extended

SortBuffer supports reading data from the specified channel index

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

Motivation

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.

Changes

SortBuffer supports reading data from the specified channel index.

Test

This change added tests.

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