public class StreamExecPythonCalc extends CommonExecPythonCalc implements StreamExecNode<RowData>
ExecNode
for Python ScalarFunctions.FIELD_NAME_PROJECTION
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecPythonCalc(List<org.apache.calcite.rex.RexNode> projection,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecPythonCalc(List<org.apache.calcite.rex.RexNode> projection,
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 StreamExecPythonCalc(List<org.apache.calcite.rex.RexNode> projection, InputProperty inputProperty, RowType outputType, String description)
public StreamExecPythonCalc(List<org.apache.calcite.rex.RexNode> projection, int id, List<InputProperty> inputProperties, RowType outputType, String description)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.