public class BatchExecTableSourceScan extends CommonExecTableSourceScan implements BatchExecNode<RowData>
ExecNode
to read data from an external source defined by a bounded ScanTableSource
.FIELD_NAME_SCAN_TABLE_SOURCE
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
BatchExecTableSourceScan(DynamicTableSourceSpec tableSourceSpec,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
Transformation<RowData> |
createInputFormatTransformation(StreamExecutionEnvironment env,
InputFormat<RowData,?> inputFormat,
InternalTypeInfo<RowData> outputTypeInfo,
String name)
Creates a
Transformation based on the given InputFormat . |
getTableSourceSpec, translateToPlanInternal
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 BatchExecTableSourceScan(DynamicTableSourceSpec tableSourceSpec, RowType outputType, String description)
public Transformation<RowData> createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String name)
CommonExecTableSourceScan
Transformation
based on the given InputFormat
. The implementation
is different for streaming mode and batch mode.createInputFormatTransformation
in class CommonExecTableSourceScan
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.