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

Class StreamExecPythonCorrelate

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.stream.StreamExecPythonCorrelate

All Implemented Interfaces:

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

@ExecNodeMetadata(name="stream-exec-python-correlate",
                  version=1,
                  producedTransformations="python-correlate",
                  minPlanVersion=v1_16,
                  minStateVersion=v1_16)
public class StreamExecPythonCorrelate
extends CommonExecPythonCorrelate
implements StreamExecNode<RowData>

Stream 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, PYTHON_CORRELATE_TRANSFORMATION

Fields inherited from interface 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

Constructor Summary

Constructors

Constructor and Description
StreamExecPythonCorrelate(int id, ExecNodeContext context, ReadableConfig persistedConfig, FlinkJoinType joinType, org.apache.calcite.rex.RexNode invocation, List<InputProperty> inputProperties, RowType outputType, String description)
StreamExecPythonCorrelate(ReadableConfig tableConfig, 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, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, getTransformation, inputsContainSingleton, replaceInputEdge, resetTransformation, setCompiled, 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, setCompiled, setInputEdges

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

translateToPlan

Constructor Detail

StreamExecPythonCorrelate

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

StreamExecPythonCorrelate

public StreamExecPythonCorrelate(int id,
                                 ExecNodeContext context,
                                 ReadableConfig persistedConfig,
                                 FlinkJoinType joinType,
                                 org.apache.calcite.rex.RexNode invocation,
                                 List<InputProperty> inputProperties,
                                 RowType outputType,
                                 String description)