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

Packages that use RowDataSerializer

Package	Description
org.apache.flink.table.data.writer
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat
org.apache.flink.table.runtime.keyselector
org.apache.flink.table.runtime.operators.join.deltajoin
org.apache.flink.table.runtime.operators.join.lookup
org.apache.flink.table.runtime.operators.join.window.utils
org.apache.flink.table.runtime.typeutils

Uses of RowDataSerializer in org.apache.flink.table.data.writer

Methods in org.apache.flink.table.data.writer with parameters of type RowDataSerializer

Modifier and Type	Method	Description
void	BinaryWriter.writeRow(int pos, org.apache.flink.table.data.RowData value, RowDataSerializer serializer)

Uses of RowDataSerializer in org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat

Constructors in org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat with parameters of type RowDataSerializer

Constructor	Description
InputFormatCacheLoader(org.apache.flink.api.common.io.InputFormat<org.apache.flink.table.data.RowData,?> initialInputFormat, GenericRowDataKeySelector keySelector, RowDataSerializer cacheEntriesSerializer)
InputSplitCacheLoadTask(ConcurrentHashMap<org.apache.flink.table.data.RowData,Collection<org.apache.flink.table.data.RowData>> cache, GenericRowDataKeySelector keySelector, RowDataSerializer cacheEntriesSerializer, org.apache.flink.api.common.io.InputFormat<org.apache.flink.table.data.RowData,org.apache.flink.core.io.InputSplit> inputFormat, org.apache.flink.core.io.InputSplit inputSplit)

Uses of RowDataSerializer in org.apache.flink.table.runtime.keyselector

Constructors in org.apache.flink.table.runtime.keyselector with parameters of type RowDataSerializer

Constructor	Description
GenericRowDataKeySelector(InternalTypeInfo<org.apache.flink.table.data.RowData> keyRowType, RowDataSerializer keySerializer, GeneratedProjection generatedProjection)

Uses of RowDataSerializer in org.apache.flink.table.runtime.operators.join.deltajoin

Fields in org.apache.flink.table.runtime.operators.join.deltajoin declared as RowDataSerializer

Modifier and Type	Field	Description
protected RowDataSerializer	AsyncDeltaJoinRunner.lookupSideRowSerializer

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

Constructor

Description

AsyncDeltaJoinRunner(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,Object>> generatedFetcher, DataStructureConverter<org.apache.flink.table.data.RowData,Object> fetcherConverter, GeneratedResultFuture<TableFunctionResultFuture<org.apache.flink.table.data.RowData>> generatedResultFuture, RowDataSerializer lookupSideRowSerializer, int asyncBufferCapacity, boolean treatRightAsLookupTable)

Uses of RowDataSerializer in org.apache.flink.table.runtime.operators.join.lookup

Fields in org.apache.flink.table.runtime.operators.join.lookup declared as RowDataSerializer

Modifier and Type	Field	Description
protected RowDataSerializer	AsyncLookupJoinRunner.rightRowSerializer

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

Constructor	Description
AsyncLookupJoinRunner(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,Object>> generatedFetcher, DataStructureConverter<org.apache.flink.table.data.RowData,Object> fetcherConverter, GeneratedResultFuture<TableFunctionResultFuture<org.apache.flink.table.data.RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)
AsyncLookupJoinWithCalcRunner(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,Object>> generatedFetcher, DataStructureConverter<org.apache.flink.table.data.RowData,Object> fetcherConverter, GeneratedFunction<org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>> generatedCalc, GeneratedResultFuture<TableFunctionResultFuture<org.apache.flink.table.data.RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)

Uses of RowDataSerializer in org.apache.flink.table.runtime.operators.join.window.utils

Fields in org.apache.flink.table.runtime.operators.join.window.utils declared as RowDataSerializer

Modifier and Type	Field	Description
protected RowDataSerializer	WindowJoinHelper.leftSerializer
protected RowDataSerializer	WindowJoinHelper.rightSerializer

Constructors in org.apache.flink.table.runtime.operators.join.window.utils with parameters of type RowDataSerializer

Constructor	Description
WindowJoinHelper(RowDataSerializer leftSerializer, RowDataSerializer rightSerializer, ZoneId shiftTimeZone, WindowTimerService<Long> windowTimerService, JoinConditionWithNullFilters joinCondition, org.apache.flink.streaming.api.operators.TimestampedCollector<org.apache.flink.table.data.RowData> collector, FlinkJoinType joinType)

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

Methods in org.apache.flink.table.runtime.typeutils that return RowDataSerializer

Modifier and Type	Method	Description
static <T> RowDataSerializer	InternalSerializers.create(org.apache.flink.table.types.logical.RowType type)	Creates a TypeSerializer for internal data structures of the given RowType.
RowDataSerializer	RowDataSerializer.RowDataSerializerSnapshot.restoreSerializer()
RowDataSerializer	InternalTypeInfo.toRowSerializer()