public abstract class CommonExecTableSourceScan extends ExecNodeBase<RowData> implements MultipleTransformationTranslator<RowData>
ExecNode
to read data from an external source defined by a ScanTableSource
.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_SCAN_TABLE_SOURCE |
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Modifier | Constructor and Description |
---|---|
protected |
CommonExecTableSourceScan(DynamicTableSourceSpec tableSourceSpec,
int id,
LogicalType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected abstract Transformation<RowData> |
createInputFormatTransformation(StreamExecutionEnvironment env,
InputFormat<RowData,?> inputFormat,
InternalTypeInfo<RowData> outputTypeInfo,
String name)
Creates a
Transformation based on the given InputFormat . |
DynamicTableSourceSpec |
getTableSourceSpec() |
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
public static final String FIELD_NAME_SCAN_TABLE_SOURCE
protected CommonExecTableSourceScan(DynamicTableSourceSpec tableSourceSpec, int id, LogicalType outputType, String description)
public DynamicTableSourceSpec getTableSourceSpec()
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
ExecNodeBase
translateToPlanInternal
in class ExecNodeBase<RowData>
protected abstract Transformation<RowData> createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String name)
Transformation
based on the given InputFormat
. The implementation
is different for streaming mode and batch mode.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.