public class StreamExecCorrelate extends CommonExecCorrelate implements StreamExecNode<RowData>
ExecNode
which matches along with join a Java/Scala user defined table function.FIELD_NAME_CONDITION, FIELD_NAME_FUNCTION_CALL, FIELD_NAME_JOIN_TYPE
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecCorrelate(FlinkJoinType joinType,
org.apache.calcite.rex.RexCall invocation,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecCorrelate(FlinkJoinType joinType,
org.apache.calcite.rex.RexNode invocation,
org.apache.calcite.rex.RexNode condition,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
translateToPlanInternal
accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges
translateToPlan
public StreamExecCorrelate(FlinkJoinType joinType, org.apache.calcite.rex.RexCall invocation, @Nullable org.apache.calcite.rex.RexNode condition, InputProperty inputProperty, RowType outputType, String description)
public StreamExecCorrelate(FlinkJoinType joinType, org.apache.calcite.rex.RexNode invocation, @Nullable org.apache.calcite.rex.RexNode condition, int id, List<InputProperty> inputProperties, RowType outputType, String description)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.