Package org.apache.flink.table.runtime.operators.multipleinput

Class Summary

Class	Description
BatchMultipleInputStreamOperator	A MultipleInputStreamOperatorBase to handle batch operators.
BatchMultipleInputStreamOperatorFactory	The factory to create BatchMultipleInputStreamOperator.
MultipleInputStreamOperatorBase	Base MultipleInputStreamOperator to handle multiple inputs in table module.
TableOperatorWrapper<OP extends StreamOperator<RowData>>	This class handles the close, endInput and other related logic of a StreamOperator.
TableOperatorWrapper.Edge	The edge connecting two TableOperatorWrappers.
TableOperatorWrapperGenerator	A generator that generates a TableOperatorWrapper graph from a graph of Transformation.
UnionStreamOperator	A special operator which collects all inputs' records and forwards them in MultipleInputStreamOperatorBase.