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

Packages that use RowDataTypeInfo

Package	Description
org.apache.flink.table.planner.plan.utils
org.apache.flink.table.runtime.keyselector
org.apache.flink.table.runtime.operators.deduplicate
org.apache.flink.table.runtime.operators.join.interval
org.apache.flink.table.runtime.operators.join.lookup
org.apache.flink.table.runtime.operators.join.stream
org.apache.flink.table.runtime.operators.join.stream.state
org.apache.flink.table.runtime.operators.join.temporal
org.apache.flink.table.runtime.operators.rank
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.operators.values
org.apache.flink.table.runtime.typeutils

Uses of RowDataTypeInfo in org.apache.flink.table.planner.plan.utils

Methods in org.apache.flink.table.planner.plan.utils with parameters of type RowDataTypeInfo

Modifier and Type	Method and Description
static RowDataKeySelector	KeySelectorUtil.getRowDataSelector(int[] keyFields, RowDataTypeInfo rowType) Create a RowDataKeySelector to extract keys from DataStream which type is RowDataTypeInfo.

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

Methods in org.apache.flink.table.runtime.keyselector that return RowDataTypeInfo

Modifier and Type	Method and Description
RowDataTypeInfo	RowDataKeySelector.getProducedType()
RowDataTypeInfo	EmptyRowDataKeySelector.getProducedType()
RowDataTypeInfo	BinaryRowDataKeySelector.getProducedType()

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

Constructor and Description
BinaryRowDataKeySelector(RowDataTypeInfo keyRowType, GeneratedProjection generatedProjection)

Uses of RowDataTypeInfo in org.apache.flink.table.runtime.operators.deduplicate

Constructors in org.apache.flink.table.runtime.operators.deduplicate with parameters of type RowDataTypeInfo

Constructor and Description
DeduplicateKeepLastRowFunction(long minRetentionTime, RowDataTypeInfo rowTypeInfo, boolean generateUpdateBefore, boolean generateInsert)
MiniBatchDeduplicateKeepLastRowFunction(RowDataTypeInfo rowTypeInfo, boolean generateUpdateBefore, boolean generateInsert, TypeSerializer<RowData> typeSerializer, long minRetentionTime)

Uses of RowDataTypeInfo in org.apache.flink.table.runtime.operators.join.interval

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

Constructor and Description
ProcTimeIntervalJoin(FlinkJoinType joinType, long leftLowerBound, long leftUpperBound, RowDataTypeInfo leftType, RowDataTypeInfo rightType, GeneratedFunction<FlatJoinFunction<RowData,RowData,RowData>> genJoinFunc)
RowTimeIntervalJoin(FlinkJoinType joinType, long leftLowerBound, long leftUpperBound, long allowedLateness, RowDataTypeInfo leftType, RowDataTypeInfo rightType, GeneratedFunction<FlatJoinFunction<RowData,RowData,RowData>> genJoinFunc, int leftTimeIdx, int rightTimeIdx)

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

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

Constructor and Description
AsyncLookupJoinRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher, GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture, TypeInformation<?> fetcherReturnType, RowDataTypeInfo rightRowTypeInfo, boolean isLeftOuterJoin, int asyncBufferCapacity)
AsyncLookupJoinWithCalcRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher, GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc, GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture, TypeInformation<?> fetcherReturnType, RowDataTypeInfo rightRowTypeInfo, boolean isLeftOuterJoin, int asyncBufferCapacity)

Uses of RowDataTypeInfo in org.apache.flink.table.runtime.operators.join.stream

Fields in org.apache.flink.table.runtime.operators.join.stream declared as RowDataTypeInfo

Modifier and Type	Field and Description
protected RowDataTypeInfo	AbstractStreamingJoinOperator.leftType
protected RowDataTypeInfo	AbstractStreamingJoinOperator.rightType

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

Constructor and Description
AbstractStreamingJoinOperator(RowDataTypeInfo leftType, RowDataTypeInfo rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean[] filterNullKeys, long minRetentionTime)
StreamingJoinOperator(RowDataTypeInfo leftType, RowDataTypeInfo rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean leftIsOuter, boolean rightIsOuter, boolean[] filterNullKeys, long minRetentionTime)
StreamingSemiAntiJoinOperator(boolean isAntiJoin, RowDataTypeInfo leftType, RowDataTypeInfo rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean[] filterNullKeys, long minRetentionTime)

Uses of RowDataTypeInfo in org.apache.flink.table.runtime.operators.join.stream.state

Methods in org.apache.flink.table.runtime.operators.join.stream.state that return RowDataTypeInfo

Modifier and Type	Method and Description
RowDataTypeInfo	JoinInputSideSpec.getUniqueKeyType() Returns the TypeInformation of the unique key.

Methods in org.apache.flink.table.runtime.operators.join.stream.state with parameters of type RowDataTypeInfo

Modifier and Type	Method and Description
static JoinRecordStateView	JoinRecordStateViews.create(RuntimeContext ctx, String stateName, JoinInputSideSpec inputSideSpec, RowDataTypeInfo recordType, long retentionTime) Creates a JoinRecordStateView depends on JoinInputSideSpec.
static OuterJoinRecordStateView	OuterJoinRecordStateViews.create(RuntimeContext ctx, String stateName, JoinInputSideSpec inputSideSpec, RowDataTypeInfo recordType, long retentionTime) Creates a OuterJoinRecordStateView depends on JoinInputSideSpec.
static JoinInputSideSpec	JoinInputSideSpec.withUniqueKey(RowDataTypeInfo uniqueKeyType, KeySelector<RowData,RowData> uniqueKeySelector) Creates a JoinInputSideSpec that the input has an unique key.
static JoinInputSideSpec	JoinInputSideSpec.withUniqueKeyContainedByJoinKey(RowDataTypeInfo uniqueKeyType, KeySelector<RowData,RowData> uniqueKeySelector) Creates a JoinInputSideSpec that input has an unique key and the unique key is contained by the join key.

Uses of RowDataTypeInfo in org.apache.flink.table.runtime.operators.join.temporal

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

Constructor and Description
TemporalProcessTimeJoinOperator(RowDataTypeInfo rightType, GeneratedJoinCondition generatedJoinCondition, long minRetentionTime, long maxRetentionTime)
TemporalRowTimeJoinOperator(RowDataTypeInfo leftType, RowDataTypeInfo rightType, GeneratedJoinCondition generatedJoinCondition, int leftTimeAttribute, int rightTimeAttribute, long minRetentionTime, long maxRetentionTime)

Uses of RowDataTypeInfo in org.apache.flink.table.runtime.operators.rank

Fields in org.apache.flink.table.runtime.operators.rank declared as RowDataTypeInfo

Modifier and Type	Field and Description
protected RowDataTypeInfo	AbstractTopNFunction.inputRowType

Constructors in org.apache.flink.table.runtime.operators.rank with parameters of type RowDataTypeInfo

Constructor and Description
AppendOnlyTopNFunction(long minRetentionTime, long maxRetentionTime, RowDataTypeInfo inputRowType, GeneratedRecordComparator sortKeyGeneratedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)
RetractableTopNFunction(long minRetentionTime, long maxRetentionTime, RowDataTypeInfo inputRowType, GeneratedRecordComparator generatedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, GeneratedRecordEqualiser generatedEqualiser, boolean generateUpdateBefore, boolean outputRankNumber)
UpdatableTopNFunction(long minRetentionTime, long maxRetentionTime, RowDataTypeInfo inputRowType, RowDataKeySelector rowKeySelector, GeneratedRecordComparator generatedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)

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

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

Constructor and Description
ProcTimeSortOperator(RowDataTypeInfo inputRowType, GeneratedRecordComparator gComparator)
RowTimeSortOperator(RowDataTypeInfo inputRowType, int rowTimeIdx, GeneratedRecordComparator gComparator)
StreamSortOperator(RowDataTypeInfo inputRowType, GeneratedRecordComparator gComparator)

Uses of RowDataTypeInfo in org.apache.flink.table.runtime.operators.values

Methods in org.apache.flink.table.runtime.operators.values that return RowDataTypeInfo

Modifier and Type	Method and Description
RowDataTypeInfo	ValuesInputFormat.getProducedType()

Constructors in org.apache.flink.table.runtime.operators.values with parameters of type RowDataTypeInfo

Constructor and Description
ValuesInputFormat(GeneratedInput<GenericInputFormat<RowData>> generatedInput, RowDataTypeInfo returnType)

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

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

Modifier and Type	Method and Description
static RowDataTypeInfo	RowDataTypeInfo.of(RowType rowType)