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

Class AbstractAsyncFunctionRunner<T>

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>
    Direct Known Subclasses:
    AsyncFunctionRunner, AsyncLookupJoinRunner, AsyncMLPredictRunner, AsyncVectorSearchRunner
    public abstract class AbstractAsyncFunctionRunner<T>
extends org.apache.flink.streaming.api.functions.async.RichAsyncFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>
    Base function runner for specialized table function, e.g. AsyncLookupFunction or AsyncPredictFunction.
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,​T> fetcher  
      protected GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,​T>> generatedFetcher  

    • Constructor Summary

      Constructors 
      Constructor Description
      AbstractAsyncFunctionRunner​(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,​T>> generatedFetcher)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()  
      void open​(org.apache.flink.api.common.functions.OpenContext openContext)  

      • Methods inherited from class org.apache.flink.streaming.api.functions.async.RichAsyncFunction

        asyncInvoke, setRuntimeContext

      • Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

        getIterationRuntimeContext, getRuntimeContext

      • Methods inherited from interface org.apache.flink.streaming.api.functions.async.AsyncFunction

        timeout

    • Field Detail

      • generatedFetcher

        protected final GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,​T>> generatedFetcher

      • fetcher

        protected transient org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,​T> fetcher

    • Constructor Detail

      • AbstractAsyncFunctionRunner

        public AbstractAsyncFunctionRunner​(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,​T>> generatedFetcher)

    • Method Detail

      • open

        public void open​(org.apache.flink.api.common.functions.OpenContext openContext)
          throws Exception
        Specified by:
        open in interface org.apache.flink.api.common.functions.RichFunction
        Overrides:
        open in class org.apache.flink.api.common.functions.AbstractRichFunction
        Throws:
        Exception

      • close

        public void close()
           throws Exception
        Specified by:
        close in interface org.apache.flink.api.common.functions.RichFunction
        Overrides:
        close in class org.apache.flink.api.common.functions.AbstractRichFunction
        Throws:
        Exception