public class StreamExecUnion extends CommonExecUnion implements StreamExecNode<RowData>
ExecNode
that is not a physical node and just union the inputs' records into one
node.FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecUnion(int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecUnion(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 StreamExecUnion(List<InputProperty> inputProperties, RowType outputType, String description)
public StreamExecUnion(int id, List<InputProperty> inputProperties, RowType outputType, String description)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.