Package | Description |
---|---|
org.apache.flink.table.runtime.hashtable | |
org.apache.flink.table.runtime.operators.aggregate | |
org.apache.flink.table.runtime.operators.sort |
Modifier and Type | Class and 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.
|
Modifier and Type | Class and Description |
---|---|
class |
BytesHashMapSpillMemorySegmentPool
MemorySegmentPool for
BytesHashMap to fall back to sort agg. |
Modifier and Type | Class and Description |
---|---|
class |
ListMemorySegmentPool
MemorySegment pool of a MemorySegment list.
|
Modifier and Type | Field and Description |
---|---|
protected MemorySegmentPool |
BinaryIndexedSortable.memorySegmentPool |
Modifier and Type | Method and Description |
---|---|
static BinaryKVInMemorySortBuffer |
BinaryKVInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer,
BinaryRowSerializer keySerializer,
BinaryRowSerializer valueSerializer,
RecordComparator comparator,
ArrayList<MemorySegment> recordBufferSegments,
long numElements,
MemorySegmentPool pool) |
void |
BufferedKVExternalSorter.sortAndSpill(ArrayList<MemorySegment> recordBufferSegments,
long numElements,
MemorySegmentPool pool) |
Constructor and Description |
---|
BinaryIndexedSortable(NormalizedKeyComputer normalizedKeyComputer,
BinaryRowSerializer serializer,
RecordComparator comparator,
ArrayList<MemorySegment> recordBufferSegments,
MemorySegmentPool memorySegmentPool) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.