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

类 ExecNodeBase<T>

java.lang.Object

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

类型参数:

T - The type of the elements that result from this node.

所有已实现的接口:

ExecNode<T>, ExecNodeTranslator<T>

直接已知子类:

BatchExecBoundedStreamScan, BatchExecHashAggregate, BatchExecHashJoin, BatchExecHashWindowAggregate, BatchExecLimit, BatchExecMultipleInput, BatchExecNestedLoopJoin, BatchExecOverAggregateBase, BatchExecPythonGroupAggregate, BatchExecPythonGroupWindowAggregate, BatchExecRank, BatchExecSort, BatchExecSortAggregate, BatchExecSortLimit, BatchExecSortMergeJoin, BatchExecSortWindowAggregate, CommonExecCalc, CommonExecCorrelate, CommonExecExchange, CommonExecExpand, CommonExecLegacySink, CommonExecLegacyTableSourceScan, CommonExecLookupJoin, CommonExecPythonCalc, CommonExecPythonCorrelate, CommonExecSink, CommonExecTableSourceScan, CommonExecUnion, CommonExecValues, CommonExecWindowTableFunction, StreamExecAggregateBase, StreamExecChangelogNormalize, StreamExecDataStreamScan, StreamExecDeduplicate, StreamExecDropUpdateBefore, StreamExecGroupTableAggregate, StreamExecIntervalJoin, StreamExecJoin, StreamExecMatch, StreamExecMiniBatchAssigner, StreamExecMultipleInput, StreamExecOverAggregate, StreamExecPythonGroupTableAggregate, StreamExecPythonOverAggregate, StreamExecRank, StreamExecSort, StreamExecTemporalJoin, StreamExecTemporalSort, StreamExecWatermarkAssigner, StreamExecWindowDeduplicate, StreamExecWindowJoin, StreamExecWindowRank

public abstract class ExecNodeBase<T>
extends Object
implements ExecNode<T>

Base class for ExecNode.

字段概要

从接口继承的字段 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_TYPE

构造器概要

构造器

限定符	构造器和说明
protected	ExecNodeBase(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.LogicalType outputType, String description)

方法概要

限定符和类型	方法和说明
void	accept(ExecNodeVisitor visitor) Accepts a visit from a ExecNodeVisitor.
protected String	createFormattedTransformationDescription(String description, org.apache.flink.configuration.ReadableConfig config)
protected String	createFormattedTransformationName(String detailName, String simplifiedName, org.apache.flink.configuration.ReadableConfig config)
protected String	createTransformationDescription(org.apache.flink.configuration.ReadableConfig config)
protected TransformationMetadata	createTransformationMeta(String operatorName, org.apache.flink.configuration.ReadableConfig config)
protected TransformationMetadata	createTransformationMeta(String operatorName, String detailName, String simplifiedName, org.apache.flink.configuration.ReadableConfig config)
protected String	createTransformationName(org.apache.flink.configuration.ReadableConfig config)
protected String	createTransformationUid(String operatorName)
protected ExecNodeContext	getContextFromAnnotation() Retrieves the default context from the ExecNodeMetadata annotation to be serialized into the JSON plan.
String	getDescription() Returns a string which describes this node.
int	getId() The unique ID of the node.
List<ExecEdge>	getInputEdges() Returns a list of this node's input ExecEdges.
List<InputProperty>	getInputProperties() Returns a list of this node's input properties.
org.apache.flink.table.types.logical.LogicalType	getOutputType() Returns the output LogicalType of this node, this type should be consistent with the type parameter T.
org.apache.flink.configuration.ReadableConfig	getPersistedConfig()
protected String	getSimplifiedName()
protected boolean	inputsContainSingleton() Whether singleton distribution is required.
void	replaceInputEdge(int index, ExecEdge newInputEdge) Replaces the ordinalInParentth input edge.
void	setInputEdges(List<ExecEdge> inputEdges) Sets the input ExecEdges which connect this nodes and its input nodes.
org.apache.flink.api.dag.Transformation<T>	translateToPlan(org.apache.flink.table.delegation.Planner planner) Translates this node into a Transformation.
protected abstract org.apache.flink.api.dag.Transformation<T>	translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config) Internal method, translates this node into a Flink operator.

从类继承的方法 java.lang.Object

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

构造器详细资料

ExecNodeBase

protected ExecNodeBase(int id,
                       ExecNodeContext context,
                       org.apache.flink.configuration.ReadableConfig persistedConfig,
                       List<InputProperty> inputProperties,
                       org.apache.flink.table.types.logical.LogicalType outputType,
                       String description)

方法详细资料

getContextFromAnnotation

protected final ExecNodeContext getContextFromAnnotation()

Retrieves the default context from the ExecNodeMetadata annotation to be serialized into the JSON plan.

getPersistedConfig

public org.apache.flink.configuration.ReadableConfig getPersistedConfig()

getId

public final int getId()

从接口复制的说明: ExecNode

The unique ID of the node.

指定者:

getId 在接口中 ExecNode<T>

getDescription

public String getDescription()

从接口复制的说明: ExecNode

Returns a string which describes this node.

指定者:

getDescription 在接口中 ExecNode<T>

getOutputType

public org.apache.flink.table.types.logical.LogicalType getOutputType()

从接口复制的说明: ExecNode

Returns the output LogicalType of this node, this type should be consistent with the type parameter T.

Such as, if T is RowData, the output type should be RowType. please refer to the JavaDoc of RowData for more info about mapping of logical types to internal data structures.

指定者:

getOutputType 在接口中 ExecNode<T>

getInputProperties

public List<InputProperty> getInputProperties()

从接口复制的说明: ExecNode

Returns a list of this node's input properties.

NOTE: If there are no inputs, returns an empty list, not null.

指定者:

getInputProperties 在接口中 ExecNode<T>

返回:

List of this node's input properties.

getInputEdges

public List<ExecEdge> getInputEdges()

从接口复制的说明: ExecNode

Returns a list of this node's input ExecEdges.

NOTE: If there are no inputs, returns an empty list, not null.

指定者:

getInputEdges 在接口中 ExecNode<T>

setInputEdges

public void setInputEdges(List<ExecEdge> inputEdges)

从接口复制的说明: ExecNode

Sets the input ExecEdges which connect this nodes and its input nodes.

NOTE: If there are no inputs, the given inputEdges should be empty, not null.

指定者:

setInputEdges 在接口中 ExecNode<T>

参数:

inputEdges - the input ExecEdges.

replaceInputEdge

public void replaceInputEdge(int index,
                             ExecEdge newInputEdge)

从接口复制的说明: ExecNode

Replaces the ordinalInParent^th input edge.

指定者:

replaceInputEdge 在接口中 ExecNode<T>

参数:

index - Position of the child input edge, 0 is the first.

newInputEdge - New edge that should be put at position `index`.

translateToPlan

public final org.apache.flink.api.dag.Transformation<T> translateToPlan(org.apache.flink.table.delegation.Planner planner)

从接口复制的说明: ExecNodeTranslator

Translates this node into a Transformation.

NOTE: This method should return same translate result if called multiple times.

指定者:

translateToPlan 在接口中 ExecNodeTranslator<T>

参数:

planner - The Planner of the translated Table.

translateToPlanInternal

protected abstract org.apache.flink.api.dag.Transformation<T> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
                                                                                      ExecNodeConfig config)

Internal method, translates this node into a Flink operator.

参数:

planner - 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.

accept

public void accept(ExecNodeVisitor visitor)

从接口复制的说明: ExecNode

Accepts a visit from a ExecNodeVisitor.

指定者:

accept 在接口中 ExecNode<T>

参数:

visitor - ExecNodeVisitor.

inputsContainSingleton

protected boolean inputsContainSingleton()

Whether singleton distribution is required.

getSimplifiedName

protected String getSimplifiedName()

createTransformationUid

protected String createTransformationUid(String operatorName)

createTransformationName

protected String createTransformationName(org.apache.flink.configuration.ReadableConfig config)

createTransformationDescription

protected String createTransformationDescription(org.apache.flink.configuration.ReadableConfig config)

createTransformationMeta

protected TransformationMetadata createTransformationMeta(String operatorName,
                                                          org.apache.flink.configuration.ReadableConfig config)

createTransformationMeta

protected TransformationMetadata createTransformationMeta(String operatorName,
                                                          String detailName,
                                                          String simplifiedName,
                                                          org.apache.flink.configuration.ReadableConfig config)

createFormattedTransformationDescription

protected String createFormattedTransformationDescription(String description,
                                                          org.apache.flink.configuration.ReadableConfig config)

createFormattedTransformationName

protected String createFormattedTransformationName(String detailName,
                                                   String simplifiedName,
                                                   org.apache.flink.configuration.ReadableConfig config)