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