Uses of Interface
org.apache.flink.table.runtime.generated.NormalizedKeyComputer

Packages that use NormalizedKeyComputer

Package	Description
org.apache.flink.table.runtime.operators.sort

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

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

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)

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

Constructor and Description
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)
BufferedKVExternalSorter(IOManager ioManager, BinaryRowDataSerializer keySerializer, BinaryRowDataSerializer valueSerializer, NormalizedKeyComputer nKeyComputer, RecordComparator comparator, int pageSize, Configuration conf)