THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Status
...
Page properties | |
---|---|
|
...
...
|
...
|
...
|
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
SortMergePartitionReader: Subpartition data reader for link SortMergeResultPartition. (Override methods are mainly inherited from ResultSubpartitionView and BufferRecycler)
public
...
class SortMergeSubpartitionReader
implements ResultSubpartitionView, Comparable<SortMergeSubpartitionReader> {
@Nullable
@Override
public BufferAndBacklog getNextBuffer() throws IOException;
@Override
/** This method is called by the IO thread of {@link SortMergeResultPartitionReadScheduler}. */
public boolean readBuffers(Queue<MemorySegment> buffers, BufferRecycler recycler) throws IOException;
public CompletableFuture<?> getReleaseFuture();
public void fail(Throwable throwable);
@Override
public void notifyDataAvailable();
@Override
public int compareTo(SortMergeSubpartitionReader that);
@Override
public void notifyDataAvailable releaseAllResources();
@Override
public boolean isReleased();
@Override
public void recycleresumeConsumption(MemorySegment segment);
@Override
public voidThrowable releaseAllResourcesgetFailureCause();
@Override
public boolean isAvailable(int numCreditsAvailable);
@Override
public int unsynchronizedGetNumberOfQueuedBuffers();
}
The interface of SortBuffer is flexible enough and new requirements like sorting by record can be also implemented easily if needed.
...