Class AsyncFunctionRunner

  • 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>

    public class AsyncFunctionRunner
    extends org.apache.flink.streaming.api.functions.async.RichAsyncFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>
    Async function runner for AsyncScalarFunction, which takes the generated function, instantiates it, and then calls its lifecycle methods.
    See Also:
    Serialized Form
    • Constructor Summary

      Constructors 
      Constructor Description
      AsyncFunctionRunner​(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>> generatedFetcher)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void asyncInvoke​(org.apache.flink.table.data.RowData input, org.apache.flink.streaming.api.functions.async.ResultFuture<org.apache.flink.table.data.RowData> resultFuture)  
      void close()  
      void open​(org.apache.flink.api.common.functions.OpenContext openContext)  
      • Methods inherited from class org.apache.flink.streaming.api.functions.async.RichAsyncFunction

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

        getIterationRuntimeContext, getRuntimeContext, open
      • Methods inherited from interface org.apache.flink.streaming.api.functions.async.AsyncFunction

        timeout
    • Constructor Detail

      • AsyncFunctionRunner

        public AsyncFunctionRunner​(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>> generatedFetcher)
    • Method Detail

      • open

        public void open​(org.apache.flink.api.common.functions.OpenContext openContext)
                  throws Exception
        Throws:
        Exception
      • asyncInvoke

        public void asyncInvoke​(org.apache.flink.table.data.RowData input,
                                org.apache.flink.streaming.api.functions.async.ResultFuture<org.apache.flink.table.data.RowData> resultFuture)
        Specified by:
        asyncInvoke in interface org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>
        Specified by:
        asyncInvoke in class org.apache.flink.streaming.api.functions.async.RichAsyncFunction<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>
      • 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