public class StreamExecExpand extends CommonExecExpand implements StreamExecNode<RowData>
ExecNode
that can expand one row to multiple rows based on given projects.FIELD_NAME_PROJECTS
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecExpand(List<List<org.apache.calcite.rex.RexNode>> projects,
InputProperty inputProperty,
RowType outputType,
String description) |
StreamExecExpand(List<List<org.apache.calcite.rex.RexNode>> projects,
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 StreamExecExpand(List<List<org.apache.calcite.rex.RexNode>> projects, InputProperty inputProperty, RowType outputType, String description)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.