Uses of Class
org.apache.flink.table.runtime.typeutils.BinaryRowDataSerializer

Packages that use BinaryRowDataSerializer

Package	Description
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.io
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.sort

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

Methods in org.apache.flink.table.runtime.hashtable with parameters of type BinaryRowDataSerializer

Modifier and Type	Method and Description
static void	LongHashPartition.deserializeFromPages(BinaryRowData reuse, ChannelReaderInputView inView, BinaryRowDataSerializer buildSideSerializer)

Constructors in org.apache.flink.table.runtime.hashtable with parameters of type BinaryRowDataSerializer

Constructor and Description
LongHybridHashTable(Object owner, boolean compressionEnabled, int compressionBlockSize, BinaryRowDataSerializer buildSideSerializer, BinaryRowDataSerializer probeSideSerializer, MemoryManager memManager, long reservedMemorySize, IOManager ioManager, int avgRecordLen, long buildRowCount)

Uses of BinaryRowDataSerializer in org.apache.flink.table.runtime.io

Fields in org.apache.flink.table.runtime.io declared as BinaryRowDataSerializer

Modifier and Type	Field and Description
protected BinaryRowDataSerializer	BinaryRowChannelInputViewIterator.serializer

Constructors in org.apache.flink.table.runtime.io with parameters of type BinaryRowDataSerializer

Constructor and Description
BinaryRowChannelInputViewIterator(ChannelReaderInputView inView, BinaryRowDataSerializer serializer)
BinaryRowChannelInputViewIterator(ChannelReaderInputView inView, List<MemorySegment> freeMemTarget, BinaryRowDataSerializer serializer)
LongHashPartitionChannelReaderInputViewIterator(ChannelReaderInputView inView, BinaryRowDataSerializer serializer)

Uses of BinaryRowDataSerializer in org.apache.flink.table.runtime.operators.join

Constructors in org.apache.flink.table.runtime.operators.join with parameters of type BinaryRowDataSerializer

Constructor and Description
SortMergeFullOuterJoinIterator(BinaryRowDataSerializer serializer1, BinaryRowDataSerializer serializer2, Projection<RowData,BinaryRowData> projection1, Projection<RowData,BinaryRowData> projection2, RecordComparator keyComparator, MutableObjectIterator<BinaryRowData> iterator1, MutableObjectIterator<BinaryRowData> iterator2, ResettableExternalBuffer buffer1, ResettableExternalBuffer buffer2, boolean[] filterNulls)
SortMergeInnerJoinIterator(BinaryRowDataSerializer probeSerializer, BinaryRowDataSerializer bufferedSerializer, Projection probeProjection, Projection bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<RowData> probeIterator, MutableObjectIterator<BinaryRowData> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)
SortMergeJoinIterator(BinaryRowDataSerializer probeSerializer, BinaryRowDataSerializer bufferedSerializer, Projection<RowData,BinaryRowData> probeProjection, Projection<RowData,BinaryRowData> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<RowData> probeIterator, MutableObjectIterator<BinaryRowData> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNulls)
SortMergeOneSideOuterJoinIterator(BinaryRowDataSerializer probeSerializer, BinaryRowDataSerializer bufferedSerializer, Projection<RowData,BinaryRowData> probeProjection, Projection<RowData,BinaryRowData> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<RowData> probeIterator, MutableObjectIterator<BinaryRowData> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)

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

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

Modifier and Type	Field and Description
protected BinaryRowDataSerializer	BinaryIndexedSortable.serializer
protected BinaryRowDataSerializer	BinaryIndexedSortable.serializer1

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

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 BinaryRowDataSerializer

Constructor and Description
BinaryExternalMerger(IOManager ioManager, int pageSize, int maxFanIn, SpillChannelManager channelManager, BinaryRowDataSerializer serializer, RecordComparator comparator, boolean compressionEnabled, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)
BinaryExternalSorter(Object owner, MemoryManager memoryManager, long reservedMemorySize, IOManager ioManager, AbstractRowDataSerializer<RowData> inputSerializer, BinaryRowDataSerializer serializer, NormalizedKeyComputer normalizedKeyComputer, RecordComparator comparator, int maxNumFileHandles, boolean compressionEnabled, int compressionBlockSize, boolean asyncMergeEnabled)
BinaryExternalSorter(Object owner, MemoryManager memoryManager, long reservedMemorySize, IOManager ioManager, AbstractRowDataSerializer<RowData> inputSerializer, BinaryRowDataSerializer serializer, NormalizedKeyComputer normalizedKeyComputer, RecordComparator comparator, int maxNumFileHandles, boolean compressionEnabled, int compressionBlockSize, boolean asyncMergeEnabled, 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 compressionEnabled, BlockCompressionFactory compressionCodecFactory, int compressionBlockSize)
BufferedKVExternalSorter(IOManager ioManager, BinaryRowDataSerializer keySerializer, BinaryRowDataSerializer valueSerializer, NormalizedKeyComputer nKeyComputer, RecordComparator comparator, int pageSize, int maxNumFileHandles, boolean compressionEnabled, int compressionBlockSize)