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