Modifier and Type | Method and Description |
---|---|
static BaseRowKeySelector |
KeySelectorUtil.getBaseRowSelector(int[] keyFields,
BaseRowTypeInfo rowType)
Create a BaseRowKeySelector to extract keys from DataStream which type is BaseRowTypeInfo.
|
Modifier and Type | Method and Description |
---|---|
BaseRowTypeInfo |
BinaryRowKeySelector.getProducedType() |
BaseRowTypeInfo |
NullBinaryRowKeySelector.getProducedType() |
BaseRowTypeInfo |
BaseRowKeySelector.getProducedType() |
Constructor and Description |
---|
BinaryRowKeySelector(BaseRowTypeInfo keyRowType,
GeneratedProjection generatedProjection) |
Constructor and Description |
---|
DeduplicateKeepLastRowFunction(long minRetentionTime,
long maxRetentionTime,
BaseRowTypeInfo rowTypeInfo,
boolean generateRetraction) |
MiniBatchDeduplicateKeepLastRowFunction(BaseRowTypeInfo rowTypeInfo,
boolean generateRetraction,
TypeSerializer<BaseRow> typeSerializer) |
Constructor and Description |
---|
ProcTimeBoundedStreamJoin(FlinkJoinType joinType,
long leftLowerBound,
long leftUpperBound,
BaseRowTypeInfo leftType,
BaseRowTypeInfo rightType,
GeneratedFunction<FlatJoinFunction<BaseRow,BaseRow,BaseRow>> genJoinFunc) |
RowTimeBoundedStreamJoin(FlinkJoinType joinType,
long leftLowerBound,
long leftUpperBound,
long allowedLateness,
BaseRowTypeInfo leftType,
BaseRowTypeInfo rightType,
GeneratedFunction<FlatJoinFunction<BaseRow,BaseRow,BaseRow>> genJoinFunc,
int leftTimeIdx,
int rightTimeIdx) |
Constructor and Description |
---|
AsyncLookupJoinRunner(GeneratedFunction<AsyncFunction<BaseRow,Object>> generatedFetcher,
GeneratedResultFuture<TableFunctionResultFuture<BaseRow>> generatedResultFuture,
TypeInformation<?> fetcherReturnType,
BaseRowTypeInfo rightRowTypeInfo,
boolean isLeftOuterJoin,
int asyncBufferCapacity) |
AsyncLookupJoinWithCalcRunner(GeneratedFunction<AsyncFunction<BaseRow,Object>> generatedFetcher,
GeneratedFunction<FlatMapFunction<BaseRow,BaseRow>> generatedCalc,
GeneratedResultFuture<TableFunctionResultFuture<BaseRow>> generatedResultFuture,
TypeInformation<?> fetcherReturnType,
BaseRowTypeInfo rightRowTypeInfo,
boolean isLeftOuterJoin,
int asyncBufferCapacity) |
Modifier and Type | Field and Description |
---|---|
protected BaseRowTypeInfo |
AbstractStreamingJoinOperator.leftType |
protected BaseRowTypeInfo |
AbstractStreamingJoinOperator.rightType |
Constructor and Description |
---|
AbstractStreamingJoinOperator(BaseRowTypeInfo leftType,
BaseRowTypeInfo rightType,
GeneratedJoinCondition generatedJoinCondition,
JoinInputSideSpec leftInputSideSpec,
JoinInputSideSpec rightInputSideSpec,
boolean[] filterNullKeys,
long minRetentionTime) |
StreamingJoinOperator(BaseRowTypeInfo leftType,
BaseRowTypeInfo rightType,
GeneratedJoinCondition generatedJoinCondition,
JoinInputSideSpec leftInputSideSpec,
JoinInputSideSpec rightInputSideSpec,
boolean leftIsOuter,
boolean rightIsOuter,
boolean[] filterNullKeys,
long minRetentionTime) |
StreamingSemiAntiJoinOperator(boolean isAntiJoin,
BaseRowTypeInfo leftType,
BaseRowTypeInfo rightType,
GeneratedJoinCondition generatedJoinCondition,
JoinInputSideSpec leftInputSideSpec,
JoinInputSideSpec rightInputSideSpec,
boolean[] filterNullKeys,
long minRetentionTime) |
Modifier and Type | Method and Description |
---|---|
BaseRowTypeInfo |
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,
BaseRowTypeInfo recordType,
long retentionTime,
boolean stateCleaningEnabled)
Creates a
JoinRecordStateView depends on JoinInputSideSpec . |
static OuterJoinRecordStateView |
OuterJoinRecordStateViews.create(RuntimeContext ctx,
String stateName,
JoinInputSideSpec inputSideSpec,
BaseRowTypeInfo recordType,
long retentionTime,
boolean stateCleaningEnabled)
Creates a
OuterJoinRecordStateView depends on JoinInputSideSpec . |
static JoinInputSideSpec |
JoinInputSideSpec.withUniqueKey(BaseRowTypeInfo uniqueKeyType,
KeySelector<BaseRow,BaseRow> uniqueKeySelector)
Creates a
JoinInputSideSpec that the input has an unique key. |
static JoinInputSideSpec |
JoinInputSideSpec.withUniqueKeyContainedByJoinKey(BaseRowTypeInfo uniqueKeyType,
KeySelector<BaseRow,BaseRow> uniqueKeySelector)
Creates a
JoinInputSideSpec that input has an unique key and the unique key is
contained by the join key. |
Constructor and Description |
---|
TemporalProcessTimeJoinOperator(BaseRowTypeInfo rightType,
GeneratedJoinCondition generatedJoinCondition,
long minRetentionTime,
long maxRetentionTime) |
TemporalRowTimeJoinOperator(BaseRowTypeInfo leftType,
BaseRowTypeInfo rightType,
GeneratedJoinCondition generatedJoinCondition,
int leftTimeAttribute,
int rightTimeAttribute,
long minRetentionTime,
long maxRetentionTime) |
Modifier and Type | Field and Description |
---|---|
protected BaseRowTypeInfo |
AbstractTopNFunction.inputRowType |
Constructor and Description |
---|
AppendOnlyTopNFunction(long minRetentionTime,
long maxRetentionTime,
BaseRowTypeInfo inputRowType,
GeneratedRecordComparator sortKeyGeneratedRecordComparator,
BaseRowKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
boolean generateRetraction,
boolean outputRankNumber,
long cacheSize) |
RetractableTopNFunction(long minRetentionTime,
long maxRetentionTime,
BaseRowTypeInfo inputRowType,
GeneratedRecordComparator generatedRecordComparator,
BaseRowKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
GeneratedRecordEqualiser generatedEqualiser,
boolean generateRetraction,
boolean outputRankNumber) |
UpdatableTopNFunction(long minRetentionTime,
long maxRetentionTime,
BaseRowTypeInfo inputRowType,
BaseRowKeySelector rowKeySelector,
GeneratedRecordComparator generatedRecordComparator,
BaseRowKeySelector sortKeySelector,
RankType rankType,
RankRange rankRange,
boolean generateRetraction,
boolean outputRankNumber,
long cacheSize) |
Constructor and Description |
---|
ProcTimeSortOperator(BaseRowTypeInfo inputRowType,
GeneratedRecordComparator gComparator) |
RowTimeSortOperator(BaseRowTypeInfo inputRowType,
int rowTimeIdx,
GeneratedRecordComparator gComparator) |
StreamSortOperator(BaseRowTypeInfo inputRowType,
GeneratedRecordComparator gComparator) |
Modifier and Type | Method and Description |
---|---|
BaseRowTypeInfo |
ValuesInputFormat.getProducedType() |
Constructor and Description |
---|
ValuesInputFormat(GeneratedInput<GenericInputFormat<BaseRow>> generatedInput,
BaseRowTypeInfo returnType) |
Modifier and Type | Method and Description |
---|---|
static BaseRowTypeInfo |
BaseRowTypeInfo.of(RowType rowType) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.