Package | Description |
---|---|
org.apache.flink.table.runtime.operators.join | |
org.apache.flink.table.runtime.operators.rank | |
org.apache.flink.table.runtime.operators.sort |
Modifier and Type | Field and Description |
---|---|
protected RecordComparator |
SortMergeJoinIterator.keyComparator |
Modifier and Type | Class and Description |
---|---|
class |
ComparableRecordComparator
Because it's impossible to restore a
RecordComparator instance generated by GeneratedRecordComparator from checkpoint snapshot. |
Modifier and Type | Method and Description |
---|---|
static BinaryInMemorySortBuffer |
BinaryInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer,
AbstractRowDataSerializer<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<MemorySegment> recordBufferSegments,
long numElements,
MemorySegmentPool pool) |
Constructor and Description |
---|
BinaryExternalMerger(IOManager ioManager,
int pageSize,
int maxFanIn,
SpillChannelManager channelManager,
BinaryRowDataSerializer serializer,
RecordComparator comparator,
boolean compressionEnable,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
BinaryExternalSorter(Object owner,
MemoryManager memoryManager,
long reservedMemorySize,
IOManager ioManager,
AbstractRowDataSerializer<RowData> inputSerializer,
BinaryRowDataSerializer serializer,
NormalizedKeyComputer normalizedKeyComputer,
RecordComparator comparator,
Configuration conf) |
BinaryExternalSorter(Object owner,
MemoryManager memoryManager,
long reservedMemorySize,
IOManager ioManager,
AbstractRowDataSerializer<RowData> inputSerializer,
BinaryRowDataSerializer serializer,
NormalizedKeyComputer normalizedKeyComputer,
RecordComparator comparator,
Configuration conf,
float startSpillingFraction) |
BinaryIndexedSortable(NormalizedKeyComputer normalizedKeyComputer,
BinaryRowDataSerializer serializer,
RecordComparator comparator,
ArrayList<MemorySegment> recordBufferSegments,
MemorySegmentPool memorySegmentPool) |
BinaryKVExternalMerger(IOManager ioManager,
int pageSize,
int maxFanIn,
SpillChannelManager channelManager,
BinaryRowDataSerializer keySerializer,
BinaryRowDataSerializer valueSerializer,
RecordComparator comparator,
boolean compressionEnable,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
BufferedKVExternalSorter(IOManager ioManager,
BinaryRowDataSerializer keySerializer,
BinaryRowDataSerializer valueSerializer,
NormalizedKeyComputer nKeyComputer,
RecordComparator comparator,
int pageSize,
Configuration conf) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.