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

Class CommonExecExpand

java.lang.Object

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

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

All Implemented Interfaces:

ExecNode<RowData>, ExecNodeTranslator<RowData>, SingleTransformationTranslator<RowData>

Direct Known Subclasses:

BatchExecExpand, StreamExecExpand

public abstract class CommonExecExpand
extends ExecNodeBase<RowData>
implements SingleTransformationTranslator<RowData>

Base ExecNode that can expand one row to multiple rows based on given projects.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_PROJECTS

Fields inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode

FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE

Constructor Summary

Constructors

Constructor and Description
CommonExecExpand(List<List<org.apache.calcite.rex.RexNode>> projects, boolean retainHeader, int id, List<InputProperty> inputProperties, RowType outputType, String description)

Method Summary

Modifier and Type	Method and Description
protected Transformation<RowData>	translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner) Internal method, translates this node into a Flink operator.

Methods inherited from class org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase

accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNodeTranslator

translateToPlan

Field Detail

FIELD_NAME_PROJECTS

public static final String FIELD_NAME_PROJECTS

See Also:

Constant Field Values

Constructor Detail

CommonExecExpand

public CommonExecExpand(List<List<org.apache.calcite.rex.RexNode>> projects,
                        boolean retainHeader,
                        int id,
                        List<InputProperty> inputProperties,
                        RowType outputType,
                        String description)

Method Detail

translateToPlanInternal

protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)

Description copied from class: ExecNodeBase

Internal method, translates this node into a Flink operator.

Specified by:

translateToPlanInternal in class ExecNodeBase<RowData>