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

Packages that use AbstractRowSerializer

Package	Description
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.typeutils
org.apache.flink.table.runtime.util

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

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

Constructor and Description
BinaryHashTable(Configuration conf, Object owner, AbstractRowSerializer buildSideSerializer, AbstractRowSerializer probeSideSerializer, Projection<BaseRow,BinaryRow> buildSideProjection, Projection<BaseRow,BinaryRow> probeSideProjection, MemoryManager memManager, long reservedMemorySize, IOManager ioManager, int avgRecordLen, long buildRowCount, boolean useBloomFilters, HashJoinType type, JoinCondition condFunc, boolean reverseJoin, boolean[] filterNulls, boolean tryDistinctBuildRow)
BinaryHashTable(Configuration conf, Object owner, AbstractRowSerializer buildSideSerializer, AbstractRowSerializer probeSideSerializer, Projection<BaseRow,BinaryRow> buildSideProjection, Projection<BaseRow,BinaryRow> probeSideProjection, MemoryManager memManager, long reservedMemorySize, IOManager ioManager, int avgRecordLen, long buildRowCount, boolean useBloomFilters, HashJoinType type, JoinCondition condFunc, boolean reverseJoin, boolean[] filterNulls, boolean tryDistinctBuildRow)

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

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

Modifier and Type	Method and Description
static BinaryInMemorySortBuffer	BinaryInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer, AbstractRowSerializer<BaseRow> inputSerializer, BinaryRowSerializer serializer, RecordComparator comparator, List<MemorySegment> memory) Create a memory sorter in `insert` way.

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

Constructor and Description
BinaryExternalSorter(Object owner, MemoryManager memoryManager, long reservedMemorySize, IOManager ioManager, AbstractRowSerializer<BaseRow> inputSerializer, BinaryRowSerializer serializer, NormalizedKeyComputer normalizedKeyComputer, RecordComparator comparator, Configuration conf)
BinaryExternalSorter(Object owner, MemoryManager memoryManager, long reservedMemorySize, IOManager ioManager, AbstractRowSerializer<BaseRow> inputSerializer, BinaryRowSerializer serializer, NormalizedKeyComputer normalizedKeyComputer, RecordComparator comparator, Configuration conf, float startSpillingFraction)

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

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

Modifier and Type	Class and Description
class	BaseRowSerializer Serializer for BaseRow.
class	BinaryRowSerializer Serializer for BinaryRow.

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

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

Constructor and Description
ResettableExternalBuffer(MemoryManager memoryManager, IOManager ioManager, List<MemorySegment> memory, AbstractRowSerializer serializer, boolean isRowAllInFixedPart)