public abstract class CommonExecLegacyTableSourceScan extends ExecNodeBase<RowData> implements MultipleTransformationTranslator<RowData>
ExecNode
to read data from an external source defined by a StreamTableSource
.Modifier and Type | Field and Description |
---|---|
protected List<String> |
qualifiedName |
protected TableSource<?> |
tableSource |
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
CommonExecLegacyTableSourceScan(TableSource<?> tableSource,
List<String> qualifiedName,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected int[] |
computeIndexMapping(boolean isStreaming) |
protected abstract Transformation<RowData> |
createConversionTransformationIfNeeded(org.apache.flink.table.planner.delegation.PlannerBase planner,
Transformation<?> sourceTransform,
org.apache.calcite.rex.RexNode rowtimeExpression) |
protected abstract <IN> Transformation<IN> |
createInput(StreamExecutionEnvironment env,
InputFormat<IN,? extends InputSplit> inputFormat,
TypeInformation<IN> typeInfo) |
protected boolean |
needInternalConversion(int[] fieldIndexes) |
protected Transformation<RowData> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
Internal method, translates this node into a Flink operator.
|
accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
translateToPlan
protected final TableSource<?> tableSource
public CommonExecLegacyTableSourceScan(TableSource<?> tableSource, List<String> qualifiedName, RowType outputType, String description)
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
ExecNodeBase
translateToPlanInternal
in class ExecNodeBase<RowData>
protected abstract <IN> Transformation<IN> createInput(StreamExecutionEnvironment env, InputFormat<IN,? extends InputSplit> inputFormat, TypeInformation<IN> typeInfo)
protected abstract Transformation<RowData> createConversionTransformationIfNeeded(org.apache.flink.table.planner.delegation.PlannerBase planner, Transformation<?> sourceTransform, @Nullable org.apache.calcite.rex.RexNode rowtimeExpression)
protected boolean needInternalConversion(int[] fieldIndexes)
protected int[] computeIndexMapping(boolean isStreaming)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.