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

接口 ExecNode<T>

类型参数:

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

所有超级接口:

ExecNodeTranslator<T>

所有已知子接口:

BatchExecNode<T>, InputSortedExecNode<T>, StreamExecNode<T>

所有已知实现类:

BatchExecBoundedStreamScan, BatchExecCalc, BatchExecCorrelate, BatchExecExchange, BatchExecExpand, BatchExecHashAggregate, BatchExecHashJoin, BatchExecHashWindowAggregate, BatchExecLegacySink, BatchExecLegacyTableSourceScan, BatchExecLimit, BatchExecLookupJoin, BatchExecMultipleInput, BatchExecNestedLoopJoin, BatchExecOverAggregate, BatchExecOverAggregateBase, BatchExecPythonCalc, BatchExecPythonCorrelate, BatchExecPythonGroupAggregate, BatchExecPythonGroupWindowAggregate, BatchExecPythonOverAggregate, BatchExecRank, BatchExecSink, BatchExecSort, BatchExecSortAggregate, BatchExecSortLimit, BatchExecSortMergeJoin, BatchExecSortWindowAggregate, BatchExecTableSourceScan, BatchExecUnion, BatchExecValues, BatchExecWindowTableFunction, CommonExecCalc, CommonExecCorrelate, CommonExecExchange, CommonExecExpand, CommonExecLegacySink, CommonExecLegacyTableSourceScan, CommonExecLookupJoin, CommonExecPythonCalc, CommonExecPythonCorrelate, CommonExecSink, CommonExecTableSourceScan, CommonExecUnion, CommonExecValues, CommonExecWindowTableFunction, ExecNodeBase, StreamExecAggregateBase, StreamExecCalc, StreamExecChangelogNormalize, StreamExecCorrelate, StreamExecDataStreamScan, StreamExecDeduplicate, StreamExecDropUpdateBefore, StreamExecExchange, StreamExecExpand, StreamExecGlobalGroupAggregate, StreamExecGlobalWindowAggregate, StreamExecGroupAggregate, StreamExecGroupTableAggregate, StreamExecGroupWindowAggregate, StreamExecIncrementalGroupAggregate, StreamExecIntervalJoin, StreamExecJoin, StreamExecLegacySink, StreamExecLegacyTableSourceScan, StreamExecLimit, StreamExecLocalGroupAggregate, StreamExecLocalWindowAggregate, StreamExecLookupJoin, StreamExecMatch, StreamExecMiniBatchAssigner, StreamExecMultipleInput, StreamExecOverAggregate, StreamExecPythonCalc, StreamExecPythonCorrelate, StreamExecPythonGroupAggregate, StreamExecPythonGroupTableAggregate, StreamExecPythonGroupWindowAggregate, StreamExecPythonOverAggregate, StreamExecRank, StreamExecSink, StreamExecSort, StreamExecSortLimit, StreamExecTableSourceScan, StreamExecTemporalJoin, StreamExecTemporalSort, StreamExecUnion, StreamExecValues, StreamExecWatermarkAssigner, StreamExecWindowAggregate, StreamExecWindowAggregateBase, StreamExecWindowDeduplicate, StreamExecWindowJoin, StreamExecWindowRank, StreamExecWindowTableFunction

@Internal
public interface ExecNode<T>
extends ExecNodeTranslator<T>

The representation of execution information for a FlinkPhysicalRel.

字段概要

字段

限定符和类型	字段和说明
static String	FIELD_NAME_CONFIGURATION
static String	FIELD_NAME_DESCRIPTION
static String	FIELD_NAME_ID
static String	FIELD_NAME_INPUT_PROPERTIES
static String	FIELD_NAME_OUTPUT_TYPE
static String	FIELD_NAME_TYPE

方法概要

限定符和类型	方法和说明
void	accept(ExecNodeVisitor visitor) Accepts a visit from a ExecNodeVisitor.
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.
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.table.planner.plan.nodes.exec.ExecNodeTranslator

translateToPlan

字段详细资料

FIELD_NAME_ID

static final String FIELD_NAME_ID

另请参阅:

常量字段值

FIELD_NAME_TYPE

static final String FIELD_NAME_TYPE

另请参阅:

常量字段值

FIELD_NAME_CONFIGURATION

static final String FIELD_NAME_CONFIGURATION

另请参阅:

常量字段值

FIELD_NAME_DESCRIPTION

static final String FIELD_NAME_DESCRIPTION

另请参阅:

常量字段值

FIELD_NAME_INPUT_PROPERTIES

static final String FIELD_NAME_INPUT_PROPERTIES

另请参阅:

常量字段值

FIELD_NAME_OUTPUT_TYPE

static final String FIELD_NAME_OUTPUT_TYPE

另请参阅:

常量字段值

方法详细资料

getId

int getId()

The unique ID of the node.

getDescription

String getDescription()

Returns a string which describes this node.

getOutputType

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.

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.

getInputProperties

List<InputProperty> getInputProperties()

Returns a list of this node's input properties.

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

返回:

List of this node's input properties.

getInputEdges

List<ExecEdge> getInputEdges()

Returns a list of this node's input ExecEdges.

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

setInputEdges

void setInputEdges(List<ExecEdge> inputEdges)

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.

参数:

inputEdges - the input ExecEdges.

replaceInputEdge

void replaceInputEdge(int index,
                      ExecEdge newInputEdge)

Replaces the ordinalInParent^th input edge.

参数:

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

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

accept

void accept(ExecNodeVisitor visitor)

Accepts a visit from a ExecNodeVisitor.

参数:

visitor - ExecNodeVisitor.