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

Class Summary

Class	Description
AbstractAsyncFunctionRunner<T>	Base function runner for specialized table function, e.g.
AbstractFunctionRunner	Base function runner for specialized table function, e.g.
AsyncStateTableStreamOperator<OUT>	Table operator to invoke close always.
CodeGenOperatorFactory<OUT>	Stream operator factory for code gen operator.
StreamingDeltaJoinOperatorFactory	The factory of StreamingDeltaJoinOperator.
TableAbstractCoUdfStreamOperator<OUT,LEFT_FUNC extends org.apache.flink.api.common.functions.Function,RIGHT_FUNC extends org.apache.flink.api.common.functions.Function>	This is used as the base class for operators that have two user-defined function for left and right side.
TableKeyedAsyncWaitOperator<IN,OUT,KEY>	This operator serves a similar purpose to AsyncWaitOperator.
TableKeyedAsyncWaitOperatorFactory<IN,OUT,KEY>	The factory of TableKeyedAsyncWaitOperator.
TableStreamOperator<OUT>	Table operator to invoke close always.