Package org.apache.flink.table.runtime.operators
-
Class Summary Class Description AsyncStateTableStreamOperator<OUT> Table operator to invoke close always.CodeGenOperatorFactory<OUT> Stream operator factory for code gen operator.StreamingDeltaJoinOperatorFactory The factory ofStreamingDeltaJoinOperator.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 toAsyncWaitOperator.TableKeyedAsyncWaitOperatorFactory<IN,OUT,KEY> The factory ofTableKeyedAsyncWaitOperator.TableStreamOperator<OUT> Table operator to invoke close always.