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

Packages that use AbstractRowDataSerializer

Package	Description
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers
org.apache.flink.table.runtime.operators.aggregate.window
org.apache.flink.table.runtime.operators.aggregate.window.buffers
org.apache.flink.table.runtime.operators.deduplicate.window
org.apache.flink.table.runtime.operators.rank.window
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.typeutils
org.apache.flink.table.runtime.util

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

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

Constructor

Description

BinaryHashTable(Object owner, boolean compressionEnabled, int compressionBlockSize, AbstractRowDataSerializer buildSideSerializer, AbstractRowDataSerializer probeSideSerializer, Projection<org.apache.flink.table.data.RowData,org.apache.flink.table.data.binary.BinaryRowData> buildSideProjection, Projection<org.apache.flink.table.data.RowData,org.apache.flink.table.data.binary.BinaryRowData> probeSideProjection, org.apache.flink.runtime.memory.MemoryManager memManager, long reservedMemorySize, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, int avgRecordLen, long buildRowCount, boolean useBloomFilters, HashJoinType type, JoinCondition condFunc, boolean reverseJoin, boolean[] filterNulls, boolean tryDistinctBuildRow)

Uses of AbstractRowDataSerializer in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers

Constructors in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers with parameters of type AbstractRowDataSerializer

Constructor	Description
AsyncStateRecordsWindowBuffer(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, AsyncStateRecordsCombiner combineFunction, PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, RecordEqualiser keyEqualiser, AsyncStateKeyContext keyContext, ZoneId shiftTimeZone)
Factory(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, AsyncStateRecordsCombiner.Factory combinerFactory, GeneratedRecordEqualiser generatedKeyEqualiser)

Uses of AbstractRowDataSerializer in org.apache.flink.table.runtime.operators.aggregate.window

Methods in org.apache.flink.table.runtime.operators.aggregate.window with parameters of type AbstractRowDataSerializer

Modifier and Type	Method	Description
WindowAggOperatorBuilder	WindowAggOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> accSerializer)
WindowAggOperatorBuilder	WindowAggOperatorBuilder.globalAggregate(GeneratedNamespaceAggsHandleFunction<?> localGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<?> globalGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<?> stateGeneratedAggregateFunction, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> accSerializer)
WindowAggOperatorBuilder	WindowAggOperatorBuilder.inputSerializer(AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer)

Uses of AbstractRowDataSerializer in org.apache.flink.table.runtime.operators.aggregate.window.buffers

Constructors in org.apache.flink.table.runtime.operators.aggregate.window.buffers with parameters of type AbstractRowDataSerializer

Constructor	Description
Factory(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, RecordsCombiner.Factory combinerFactory)
LocalFactory(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, RecordsCombiner.LocalFactory localFactory)
RecordsWindowBuffer(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, RecordsCombiner combineFunction, PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, boolean requiresCopy, ZoneId shiftTimeZone)

Uses of AbstractRowDataSerializer in org.apache.flink.table.runtime.operators.deduplicate.window

Methods in org.apache.flink.table.runtime.operators.deduplicate.window with parameters of type AbstractRowDataSerializer

Modifier and Type	Method	Description
RowTimeWindowDeduplicateOperatorBuilder	RowTimeWindowDeduplicateOperatorBuilder.inputSerializer(AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer)

Uses of AbstractRowDataSerializer in org.apache.flink.table.runtime.operators.rank.window

Methods in org.apache.flink.table.runtime.operators.rank.window with parameters of type AbstractRowDataSerializer

Modifier and Type	Method	Description
WindowRankOperatorBuilder	WindowRankOperatorBuilder.inputSerializer(AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer)

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

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

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.

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

Constructor	Description
BinaryExternalSorter(Object owner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long reservedMemorySize, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer, BinaryRowDataSerializer serializer, NormalizedKeyComputer normalizedKeyComputer, RecordComparator comparator, int maxNumFileHandles, boolean compressionEnabled, int compressionBlockSize, boolean asyncMergeEnabled)
BinaryExternalSorter(Object owner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long reservedMemorySize, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSerializer, BinaryRowDataSerializer serializer, NormalizedKeyComputer normalizedKeyComputer, RecordComparator comparator, int maxNumFileHandles, boolean compressionEnabled, int compressionBlockSize, boolean asyncMergeEnabled, float startSpillingFraction)

Uses of AbstractRowDataSerializer in org.apache.flink.table.runtime.typeutils

Subclasses of AbstractRowDataSerializer in org.apache.flink.table.runtime.typeutils

Modifier and Type	Class	Description
class	BinaryRowDataSerializer	Serializer for BinaryRowData.
class	RowDataSerializer	Serializer for RowData.

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

Constructors in org.apache.flink.table.runtime.util with parameters of type AbstractRowDataSerializer

Constructor	Description
ResettableExternalBuffer(org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, LazyMemorySegmentPool pool, AbstractRowDataSerializer serializer, boolean isRowAllInFixedPart)