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

Packages that use InternalTypeInfo

Package	Description
org.apache.flink.table.planner.plan.nodes.exec.batch
org.apache.flink.table.planner.plan.nodes.exec.common
org.apache.flink.table.planner.plan.nodes.exec.stream
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.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 InternalTypeInfo in org.apache.flink.table.planner.plan.nodes.exec.batch

Methods in org.apache.flink.table.planner.plan.nodes.exec.batch with parameters of type InternalTypeInfo

Modifier and Type	Method and Description
Transformation<RowData>	BatchExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)

Uses of InternalTypeInfo in org.apache.flink.table.planner.plan.nodes.exec.common

Methods in org.apache.flink.table.planner.plan.nodes.exec.common with parameters of type InternalTypeInfo

Modifier and Type	Method and Description
protected abstract Transformation<RowData>	CommonExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName) Creates a Transformation based on the given InputFormat.

Uses of InternalTypeInfo in org.apache.flink.table.planner.plan.nodes.exec.stream

Methods in org.apache.flink.table.planner.plan.nodes.exec.stream with parameters of type InternalTypeInfo

Modifier and Type	Method and Description
Transformation<RowData>	StreamExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)

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

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

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

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

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

Modifier and Type	Method and Description
InternalTypeInfo<RowData>	BinaryRowDataKeySelector.getProducedType()
InternalTypeInfo<RowData>	RowDataKeySelector.getProducedType()
InternalTypeInfo<RowData>	EmptyRowDataKeySelector.getProducedType()

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

Constructor and Description
BinaryRowDataKeySelector(InternalTypeInfo<RowData> keyRowType, GeneratedProjection generatedProjection)

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

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

Constructor and Description
ProcTimeDeduplicateKeepLastRowFunction(InternalTypeInfo<RowData> typeInfo, long stateRetentionTime, boolean generateUpdateBefore, boolean generateInsert, boolean inputInsertOnly, GeneratedRecordEqualiser genRecordEqualiser)
ProcTimeMiniBatchDeduplicateKeepLastRowFunction(InternalTypeInfo<RowData> typeInfo, TypeSerializer<RowData> serializer, long stateRetentionTime, boolean generateUpdateBefore, boolean generateInsert, boolean inputInsertOnly, GeneratedRecordEqualiser genRecordEqualiser)
RowTimeDeduplicateFunction(InternalTypeInfo<RowData> typeInfo, long minRetentionTime, int rowtimeIndex, boolean generateUpdateBefore, boolean generateInsert, boolean keepLastRow)
RowTimeMiniBatchDeduplicateFunction(InternalTypeInfo<RowData> typeInfo, TypeSerializer<RowData> serializer, long minRetentionTime, int rowtimeIndex, boolean generateUpdateBefore, boolean generateInsert, boolean keepLastRow)
RowTimeMiniBatchLatestChangeDeduplicateFunction(InternalTypeInfo<RowData> typeInfo, TypeSerializer<RowData> serializer, long minRetentionTime, int rowtimeIndex, boolean generateUpdateBefore, boolean generateInsert, boolean keepLastRow)

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

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

Constructor and Description
FilterAllFlatMapFunction(InternalTypeInfo<RowData> inputTypeInfo)
IntervalJoinFunction(GeneratedJoinCondition joinCondition, InternalTypeInfo<RowData> returnTypeInfo, boolean[] filterNulls)
PaddingLeftMapFunction(OuterJoinPaddingUtil paddingUtil, InternalTypeInfo<RowData> returnType)
PaddingRightMapFunction(OuterJoinPaddingUtil paddingUtil, InternalTypeInfo<RowData> returnType)
ProcTimeIntervalJoin(FlinkJoinType joinType, long leftLowerBound, long leftUpperBound, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, IntervalJoinFunction genJoinFunc)
ProcTimeIntervalJoin(FlinkJoinType joinType, long leftLowerBound, long leftUpperBound, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, IntervalJoinFunction genJoinFunc)
RowTimeIntervalJoin(FlinkJoinType joinType, long leftLowerBound, long leftUpperBound, long allowedLateness, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, IntervalJoinFunction joinFunc, int leftTimeIdx, int rightTimeIdx)
RowTimeIntervalJoin(FlinkJoinType joinType, long leftLowerBound, long leftUpperBound, long allowedLateness, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, IntervalJoinFunction joinFunc, int leftTimeIdx, int rightTimeIdx)

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

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

Modifier and Type	Field and Description
protected InternalTypeInfo<RowData>	AbstractStreamingJoinOperator.leftType
protected InternalTypeInfo<RowData>	AbstractStreamingJoinOperator.rightType

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

Constructor and Description
AbstractStreamingJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean[] filterNullKeys, long stateRetentionTime)
AbstractStreamingJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean[] filterNullKeys, long stateRetentionTime)
StreamingJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean leftIsOuter, boolean rightIsOuter, boolean[] filterNullKeys, long stateRetentionTime)
StreamingJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean leftIsOuter, boolean rightIsOuter, boolean[] filterNullKeys, long stateRetentionTime)
StreamingSemiAntiJoinOperator(boolean isAntiJoin, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean[] filterNullKeys, long stateRetentionTime)
StreamingSemiAntiJoinOperator(boolean isAntiJoin, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean[] filterNullKeys, long stateRetentionTime)

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

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

Modifier and Type	Method and Description
InternalTypeInfo<RowData>	JoinInputSideSpec.getUniqueKeyType() Returns the TypeInformation of the unique key.

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

Modifier and Type	Method and Description
static OuterJoinRecordStateView	OuterJoinRecordStateViews.create(RuntimeContext ctx, String stateName, JoinInputSideSpec inputSideSpec, InternalTypeInfo<RowData> recordType, long retentionTime) Creates a OuterJoinRecordStateView depends on JoinInputSideSpec.
static JoinRecordStateView	JoinRecordStateViews.create(RuntimeContext ctx, String stateName, JoinInputSideSpec inputSideSpec, InternalTypeInfo<RowData> recordType, long retentionTime) Creates a JoinRecordStateView depends on JoinInputSideSpec.
static JoinInputSideSpec	JoinInputSideSpec.withUniqueKey(InternalTypeInfo<RowData> uniqueKeyType, KeySelector<RowData,RowData> uniqueKeySelector) Creates a JoinInputSideSpec that the input has an unique key.
static JoinInputSideSpec	JoinInputSideSpec.withUniqueKeyContainedByJoinKey(InternalTypeInfo<RowData> 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 InternalTypeInfo in org.apache.flink.table.runtime.operators.join.temporal

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

Constructor and Description
TemporalProcessTimeJoinOperator(InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, long minRetentionTime, long maxRetentionTime, boolean isLeftOuterJoin)
TemporalRowTimeJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, int leftTimeAttribute, int rightTimeAttribute, long minRetentionTime, long maxRetentionTime, boolean isLeftOuterJoin)
TemporalRowTimeJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, int leftTimeAttribute, int rightTimeAttribute, long minRetentionTime, long maxRetentionTime, boolean isLeftOuterJoin)

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

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

Modifier and Type	Field and Description
protected InternalTypeInfo<RowData>	AbstractTopNFunction.inputRowType

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

Constructor and Description
AppendOnlyFirstNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator sortKeyGeneratedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber)
AppendOnlyTopNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator sortKeyGeneratedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)
FastTop1Function(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator generatedSortKeyComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)
RetractableTopNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, ComparableRecordComparator comparableRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, GeneratedRecordEqualiser generatedEqualiser, boolean generateUpdateBefore, boolean outputRankNumber)
UpdatableTopNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, RowDataKeySelector rowKeySelector, GeneratedRecordComparator generatedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)

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

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

Constructor and Description
ProcTimeSortOperator(InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator gComparator)
RowTimeSortOperator(InternalTypeInfo<RowData> inputRowType, int rowTimeIdx, GeneratedRecordComparator gComparator)
StreamSortOperator(InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator gComparator)

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

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

Modifier and Type	Method and Description
InternalTypeInfo<RowData>	ValuesInputFormat.getProducedType()

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

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

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

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

Modifier and Type	Method and Description
static <T> InternalTypeInfo<T>	InternalTypeInfo.of(LogicalType type) Creates type information for a LogicalType that is represented by internal data structures.
static InternalTypeInfo<RowData>	InternalTypeInfo.of(RowType type) Creates type information for a RowType represented by internal data structures.
static InternalTypeInfo<RowData>	InternalTypeInfo.ofFields(LogicalType... fieldTypes) Creates type information for RowType represented by internal data structures.
static InternalTypeInfo<RowData>	InternalTypeInfo.ofFields(LogicalType[] fieldTypes, String[] fieldNames) Creates type information for RowType represented by internal data structures.