Package org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage

Class TieredStorageSortBuffer

java.lang.Object

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

org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage.TieredStorageSortBuffer

All Implemented Interfaces:

DataBuffer

public class TieredStorageSortBuffer
extends SortBuffer

When getting buffers, The SortBasedDataBuffer need not recycle the read target buffer..

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	Description
TieredStorageSortBuffer(LinkedList<org.apache.flink.core.memory.MemorySegment> freeSegments, BufferRecycler bufferRecycler, int numSubpartitions, int bufferSize, int numGuaranteedBuffers)

Method Summary

Modifier and Type	Method	Description
BufferWithChannel	getNextBuffer(org.apache.flink.core.memory.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

TieredStorageSortBuffer

public TieredStorageSortBuffer(LinkedList<org.apache.flink.core.memory.MemorySegment> freeSegments,
                               BufferRecycler bufferRecycler,
                               int numSubpartitions,
                               int bufferSize,
                               int numGuaranteedBuffers)

Method Detail

getNextBuffer

public BufferWithChannel getNextBuffer(@Nullable
                                       org.apache.flink.core.memory.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.