org.apache.flink.table.planner.plan.nodes.exec.stream

Class StreamExecTableSourceScan

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase<RowData>

org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan

org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecTableSourceScan

All Implemented Interfaces:

ExecNode<RowData>, ExecNodeTranslator<RowData>, FusionCodegenExecNode, MultipleTransformationTranslator<RowData>, StreamExecNode<RowData>

@ExecNodeMetadata(name="stream-exec-table-source-scan",
                  version=1,
                  producedTransformations="source",
                  minPlanVersion=v1_15,
                  minStateVersion=v1_15)
public class StreamExecTableSourceScan
extends CommonExecTableSourceScan
implements StreamExecNode<RowData>

Stream ExecNode to read data from an external source defined by a ScanTableSource.

Field Summary

Fields inherited from class org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan

FIELD_NAME_SCAN_TABLE_SOURCE, SOURCE_TRANSFORMATION

Fields inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode

FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_STATE, FIELD_NAME_TYPE

Constructor Summary

Constructors

Constructor and Description
StreamExecTableSourceScan(int id, ExecNodeContext context, ReadableConfig persistedConfig, DynamicTableSourceSpec tableSourceSpec, RowType outputType, String description)
StreamExecTableSourceScan(ReadableConfig tableConfig, DynamicTableSourceSpec tableSourceSpec, RowType outputType, String description)

Method Summary

Modifier and Type	Method and Description
Transformation<RowData>	createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName) Creates a Transformation based on the given InputFormat.

Methods inherited from class org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan

createSourceFunctionTransformation, getPhysicalRowType, getPrimaryKeyIndices, getSimplifiedName, getTableSourceSpec, translateToPlanInternal

Methods inherited from class org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase

accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getTransformation, inputsContainSingleton, replaceInputEdge, setCompiled, setInputEdges, supportFusionCodegen, translateToFusionCodegenSpec, translateToFusionCodegenSpecInternal, translateToPlan

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode

accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setCompiled, setInputEdges

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNodeTranslator

translateToPlan

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.FusionCodegenExecNode

supportFusionCodegen, translateToFusionCodegenSpec

Constructor Detail

StreamExecTableSourceScan

public StreamExecTableSourceScan(ReadableConfig tableConfig,
                                 DynamicTableSourceSpec tableSourceSpec,
                                 RowType outputType,
                                 String description)

StreamExecTableSourceScan

public StreamExecTableSourceScan(int id,
                                 ExecNodeContext context,
                                 ReadableConfig persistedConfig,
                                 DynamicTableSourceSpec tableSourceSpec,
                                 RowType outputType,
                                 String description)

Method Detail

createInputFormatTransformation

public Transformation<RowData> createInputFormatTransformation(StreamExecutionEnvironment env,
                                                               InputFormat<RowData,?> inputFormat,
                                                               InternalTypeInfo<RowData> outputTypeInfo,
                                                               String operatorName)

Description copied from class: CommonExecTableSourceScan

Creates a Transformation based on the given InputFormat. The implementation is different for streaming mode and batch mode.

Specified by:

createInputFormatTransformation in class CommonExecTableSourceScan