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

Class BatchExecPythonCorrelate

java.lang.Object

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

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

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

All Implemented Interfaces:

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

public class BatchExecPythonCorrelate
extends CommonExecPythonCorrelate
implements BatchExecNode<RowData>

Batch exec node which matches along with join a Python user defined table function.

Field Summary

Fields inherited from class org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecPythonCorrelate

FIELD_NAME_FUNCTION_CALL, FIELD_NAME_JOIN_TYPE

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
BatchExecPythonCorrelate(FlinkJoinType joinType, org.apache.calcite.rex.RexCall invocation, InputProperty inputProperty, RowType outputType, String description)

Method Summary

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

translateToPlanInternal

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

accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges

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

translateToPlan

Constructor Detail

BatchExecPythonCorrelate

public BatchExecPythonCorrelate(FlinkJoinType joinType,
                                org.apache.calcite.rex.RexCall invocation,
                                InputProperty inputProperty,
                                RowType outputType,
                                String description)