org.apache.flink.runtime.io.network.partition

Class SortBasedDataBuffer

java.lang.Object

org.apache.flink.runtime.io.network.partition.SortBuffer

org.apache.flink.runtime.io.network.partition.SortBasedDataBuffer

All Implemented Interfaces:

DataBuffer

@NotThreadSafe
public class SortBasedDataBuffer
extends SortBuffer

When getting buffers, The SortBasedDataBuffer should recycle the read target buffer with the given BufferRecycler.

Field Summary

Fields inherited from class org.apache.flink.runtime.io.network.partition.SortBuffer

bufferRecycler, freeSegments, INDEX_ENTRY_SIZE, isFinished, isReleased, lastIndexEntryAddresses, numTotalBytesRead, readIndexEntryAddress, readOrderIndex, recordRemainingBytes, segments, subpartitionReadOrder

Constructor Summary

Constructors

Constructor and Description
SortBasedDataBuffer(LinkedList<MemorySegment> freeSegments, BufferRecycler bufferRecycler, int numSubpartitions, int bufferSize, int numGuaranteedBuffers, int[] customReadOrder)

Method Summary

Modifier and Type	Method and Description
BufferWithChannel	getNextBuffer(MemorySegment transitBuffer) Copies data in this DataBuffer to the target MemorySegment in channel index order and returns BufferWithChannel which contains the copied data and the corresponding channel index.

Methods inherited from class org.apache.flink.runtime.io.network.partition.SortBuffer

append, copyRecordOrEvent, finish, getSegmentIndexFromPointer, getSegmentOffsetFromPointer, hasRemaining, isFinished, isReleased, numTotalBytes, numTotalRecords, release, updateReadChannelAndIndexEntryAddress

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SortBasedDataBuffer

public SortBasedDataBuffer(LinkedList<MemorySegment> freeSegments,
                           BufferRecycler bufferRecycler,
                           int numSubpartitions,
                           int bufferSize,
                           int numGuaranteedBuffers,
                           @Nullable
                           int[] customReadOrder)

Method Detail

getNextBuffer

public BufferWithChannel getNextBuffer(MemorySegment transitBuffer)

Description copied from interface: DataBuffer

Copies data in this DataBuffer to the target MemorySegment in channel index order and returns BufferWithChannel which contains the copied data and the corresponding channel index.