Package | Description |
---|---|
org.apache.flink.runtime.operators.sort |
Modifier and Type | Method and Description |
---|---|
protected MergeIterator<E> |
UnilateralSortMerger.SpillingThread.getMergingIterator(List<UnilateralSortMerger.ChannelWithBlockCount> channelIDs,
List<List<MemorySegment>> inputSegments,
List<FileIOChannel> readerList,
MutableObjectIterator<E> largeRecords)
Returns an iterator that iterates over the merged result from all given channels.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.