Uses of Interface
org.apache.flink.table.runtime.util.MemorySegmentPool

Packages that use MemorySegmentPool

Package	Description
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.util

Uses of MemorySegmentPool in org.apache.flink.table.runtime.hashtable

Classes in org.apache.flink.table.runtime.hashtable that implement MemorySegmentPool

Modifier and Type	Class	Description
class	BaseHybridHashTable	Base table for LongHybridHashTable and BinaryHashTable.
class	BinaryHashTable	An implementation of a Hybrid Hash Join.
class	LongHybridHashTable	Special optimized hashTable with key long.

Uses of MemorySegmentPool in org.apache.flink.table.runtime.operators.aggregate

Classes in org.apache.flink.table.runtime.operators.aggregate that implement MemorySegmentPool

Modifier and Type	Class	Description
class	BytesHashMapSpillMemorySegmentPool	MemorySegmentPool for BytesHashMap to fall back to sort agg.

Uses of MemorySegmentPool in org.apache.flink.table.runtime.operators.sort

Classes in org.apache.flink.table.runtime.operators.sort that implement MemorySegmentPool

Modifier and Type	Class	Description
class	ListMemorySegmentPool	MemorySegment pool of a MemorySegment list.

Fields in org.apache.flink.table.runtime.operators.sort declared as MemorySegmentPool

Modifier and Type	Field	Description
protected MemorySegmentPool	BinaryIndexedSortable.memorySegmentPool

Methods in org.apache.flink.table.runtime.operators.sort with parameters of type MemorySegmentPool

Modifier and Type	Method	Description
static BinaryInMemorySortBuffer	BinaryInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer, BinaryRowDataSerializer serializer, RecordComparator comparator, MemorySegmentPool memoryPool)	Create a memory sorter in `insert` way.
static BinaryKVInMemorySortBuffer	BinaryKVInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer, BinaryRowDataSerializer keySerializer, BinaryRowDataSerializer valueSerializer, RecordComparator comparator, ArrayList<org.apache.flink.core.memory.MemorySegment> recordBufferSegments, long numElements, MemorySegmentPool pool)
void	BufferedKVExternalSorter.sortAndSpill(ArrayList<org.apache.flink.core.memory.MemorySegment> recordBufferSegments, long numElements, MemorySegmentPool pool)

Constructors in org.apache.flink.table.runtime.operators.sort with parameters of type MemorySegmentPool

Constructor	Description
BinaryIndexedSortable(NormalizedKeyComputer normalizedKeyComputer, BinaryRowDataSerializer serializer, RecordComparator comparator, ArrayList<org.apache.flink.core.memory.MemorySegment> recordBufferSegments, MemorySegmentPool memorySegmentPool)

Uses of MemorySegmentPool in org.apache.flink.table.runtime.util

Classes in org.apache.flink.table.runtime.util that implement MemorySegmentPool

Modifier and Type	Class	Description
class	LazyMemorySegmentPool	MemorySegmentPool that lazy allocate memory pages from MemoryManager.