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 . |
Modifier and Type | Method and Description |
---|---|
protected static InternalTypeInfo<RowData> |
SelectTableSinkBase.createTypeInfo(TableSchema tableSchema)
Create
InternalTypeInfo of RowData based on given table schema. |
Modifier and Type | Method and Description |
---|---|
InternalTypeInfo<RowData> |
RowDataKeySelector.getProducedType() |
InternalTypeInfo<RowData> |
EmptyRowDataKeySelector.getProducedType() |
InternalTypeInfo<RowData> |
BinaryRowDataKeySelector.getProducedType() |
Constructor and Description |
---|
BinaryRowDataKeySelector(InternalTypeInfo<RowData> keyRowType,
GeneratedProjection generatedProjection) |
Constructor and Description |
---|
ProcTimeDeduplicateKeepLastRowFunction(InternalTypeInfo<RowData> typeInfo,
long stateRetentionTime,
boolean generateUpdateBefore,
boolean generateInsert,
boolean inputInsertOnly) |
ProcTimeMiniBatchDeduplicateKeepLastRowFunction(InternalTypeInfo<RowData> typeInfo,
TypeSerializer<RowData> serializer,
long stateRetentionTime,
boolean generateUpdateBefore,
boolean generateInsert,
boolean inputInsertOnly) |
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) |
Constructor and Description |
---|
AsyncLookupJoinRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher,
GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture,
TypeInformation<?> fetcherReturnType,
InternalTypeInfo<RowData> rightRowTypeInfo,
boolean isLeftOuterJoin,
int asyncBufferCapacity) |
AsyncLookupJoinWithCalcRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher,
GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc,
GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture,
TypeInformation<?> fetcherReturnType,
InternalTypeInfo<RowData> rightRowTypeInfo,
boolean isLeftOuterJoin,
int asyncBufferCapacity) |
Modifier and Type | Field and Description |
---|---|
protected InternalTypeInfo<RowData> |
AbstractStreamingJoinOperator.leftType |
protected InternalTypeInfo<RowData> |
AbstractStreamingJoinOperator.rightType |
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) |
Modifier and Type | Method and Description |
---|---|
InternalTypeInfo<RowData> |
JoinInputSideSpec.getUniqueKeyType()
Returns the
TypeInformation of the unique key. |
Modifier and Type | Method and Description |
---|---|
static JoinRecordStateView |
JoinRecordStateViews.create(RuntimeContext ctx,
String stateName,
JoinInputSideSpec inputSideSpec,
InternalTypeInfo<RowData> recordType,
long retentionTime)
Creates a
JoinRecordStateView depends on JoinInputSideSpec . |
static OuterJoinRecordStateView |
OuterJoinRecordStateViews.create(RuntimeContext ctx,
String stateName,
JoinInputSideSpec inputSideSpec,
InternalTypeInfo<RowData> recordType,
long retentionTime)
Creates a
OuterJoinRecordStateView 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. |
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) |
Modifier and Type | Field and Description |
---|---|
protected InternalTypeInfo<RowData> |
AbstractTopNFunction.inputRowType |
Constructor and Description |
---|
AppendOnlyTopNFunction(long minRetentionTime,
long maxRetentionTime,
InternalTypeInfo<RowData> inputRowType,
GeneratedRecordComparator sortKeyGeneratedRecordComparator,
RowDataKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
boolean generateUpdateBefore,
boolean outputRankNumber,
long cacheSize) |
RetractableTopNFunction(long minRetentionTime,
long maxRetentionTime,
InternalTypeInfo<RowData> inputRowType,
ComparableRecordComparator comparableRecordComparator,
RowDataKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
GeneratedRecordEqualiser generatedEqualiser,
boolean generateUpdateBefore,
boolean outputRankNumber) |
UpdatableTopNFunction(long minRetentionTime,
long maxRetentionTime,
InternalTypeInfo<RowData> inputRowType,
RowDataKeySelector rowKeySelector,
GeneratedRecordComparator generatedRecordComparator,
RowDataKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
boolean generateUpdateBefore,
boolean outputRankNumber,
long cacheSize) |
Constructor and Description |
---|
ProcTimeSortOperator(InternalTypeInfo<RowData> inputRowType,
GeneratedRecordComparator gComparator) |
RowTimeSortOperator(InternalTypeInfo<RowData> inputRowType,
int rowTimeIdx,
GeneratedRecordComparator gComparator) |
StreamSortOperator(InternalTypeInfo<RowData> inputRowType,
GeneratedRecordComparator gComparator) |
Modifier and Type | Method and Description |
---|---|
InternalTypeInfo<RowData> |
ValuesInputFormat.getProducedType() |
Constructor and Description |
---|
ValuesInputFormat(GeneratedInput<GenericInputFormat<RowData>> generatedInput,
InternalTypeInfo<RowData> returnType) |
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. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.