public class BatchExecLegacyTableSourceScan extends CommonExecLegacyTableSourceScan implements BatchExecNode<org.apache.flink.table.data.RowData>
ExecNode to read data from an external source defined by a bounded StreamTableSource.qualifiedName, tableSourceFIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_TYPE| 构造器和说明 |
|---|
BatchExecLegacyTableSourceScan(org.apache.flink.configuration.ReadableConfig tableConfig,
org.apache.flink.table.sources.TableSource<?> tableSource,
List<String> qualifiedName,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
createConversionTransformationIfNeeded(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment streamExecEnv,
ExecNodeConfig config,
org.apache.flink.api.dag.Transformation<?> sourceTransform,
org.apache.calcite.rex.RexNode rowtimeExpression) |
protected <IN> org.apache.flink.api.dag.Transformation<IN> |
createInput(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
org.apache.flink.api.common.io.InputFormat<IN,? extends org.apache.flink.core.io.InputSplit> inputFormat,
org.apache.flink.api.common.typeinfo.TypeInformation<IN> typeInfo) |
protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config)
Internal method, translates this node into a Flink operator.
|
computeIndexMapping, needInternalConversionaccept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, inputsContainSingleton, replaceInputEdge, setInputEdges, translateToPlanclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaccept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdgestranslateToPlanprotected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config)
ExecNodeBasetranslateToPlanInternal 在类中 CommonExecLegacyTableSourceScanplanner - The planner.config - per-ExecNode configuration that contains the merged configuration from
various layers which all the nodes implementing this method should use, instead of
retrieving configuration from the planner. For more details check ExecNodeConfig.protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> createConversionTransformationIfNeeded(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment streamExecEnv,
ExecNodeConfig config,
org.apache.flink.api.dag.Transformation<?> sourceTransform,
@Nullable
org.apache.calcite.rex.RexNode rowtimeExpression)
protected <IN> org.apache.flink.api.dag.Transformation<IN> createInput(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
org.apache.flink.api.common.io.InputFormat<IN,? extends org.apache.flink.core.io.InputSplit> inputFormat,
org.apache.flink.api.common.typeinfo.TypeInformation<IN> typeInfo)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.