public class StreamExecCalc extends CommonExecCalc implements StreamExecNode<RowData>
ExecNode
for Calc.FIELD_NAME_CONDITION, FIELD_NAME_PROJECTION
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecCalc(List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecCalc(List<org.apache.calcite.rex.RexNode> projection,
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 StreamExecCalc(List<org.apache.calcite.rex.RexNode> projection, @Nullable org.apache.calcite.rex.RexNode condition, InputProperty inputProperty, RowType outputType, String description)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.