Uses of Interface
org.apache.flink.streaming.api.functions.async.AsyncFunction

Packages that use AsyncFunction

Package	Description
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.async
org.apache.flink.streaming.api.operators.async
org.apache.flink.table.planner.codegen
org.apache.flink.table.runtime.operators.calc.async
org.apache.flink.table.runtime.operators.join.lookup

Uses of AsyncFunction in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type AsyncFunction

Modifier and Type	Method and Description
static <IN,OUT> SingleOutputStreamOperator<OUT>	AsyncDataStream.orderedWait(DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit) Adds an AsyncWaitOperator.
static <IN,OUT> SingleOutputStreamOperator<OUT>	AsyncDataStream.orderedWait(DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit, int capacity) Adds an AsyncWaitOperator.
static <IN,OUT> SingleOutputStreamOperator<OUT>	AsyncDataStream.orderedWaitWithRetry(DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit, AsyncRetryStrategy<OUT> asyncRetryStrategy) Adds an AsyncWaitOperator with an AsyncRetryStrategy to support retry of AsyncFunction.
static <IN,OUT> SingleOutputStreamOperator<OUT>	AsyncDataStream.orderedWaitWithRetry(DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit, int capacity, AsyncRetryStrategy<OUT> asyncRetryStrategy) Adds an AsyncWaitOperator with an AsyncRetryStrategy to support retry of AsyncFunction.
static <IN,OUT> SingleOutputStreamOperator<OUT>	AsyncDataStream.unorderedWait(DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit) Adds an AsyncWaitOperator.
static <IN,OUT> SingleOutputStreamOperator<OUT>	AsyncDataStream.unorderedWait(DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit, int capacity) Adds an AsyncWaitOperator.
static <IN,OUT> SingleOutputStreamOperator<OUT>	AsyncDataStream.unorderedWaitWithRetry(DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit, AsyncRetryStrategy<OUT> asyncRetryStrategy) Adds an AsyncWaitOperator with an AsyncRetryStrategy to support retry of AsyncFunction.
static <IN,OUT> SingleOutputStreamOperator<OUT>	AsyncDataStream.unorderedWaitWithRetry(DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit, int capacity, AsyncRetryStrategy<OUT> asyncRetryStrategy) Adds an AsyncWaitOperator with an AsyncRetryStrategy to support retry of AsyncFunction.

Uses of AsyncFunction in org.apache.flink.streaming.api.functions.async

Classes in org.apache.flink.streaming.api.functions.async that implement AsyncFunction

Modifier and Type	Class and Description
class	RichAsyncFunction<IN,OUT> Rich variant of the AsyncFunction.

Uses of AsyncFunction in org.apache.flink.streaming.api.operators.async

Constructors in org.apache.flink.streaming.api.operators.async with parameters of type AsyncFunction

Constructor and Description
AsyncWaitOperator(AsyncFunction<IN,OUT> asyncFunction, long timeout, int capacity, AsyncDataStream.OutputMode outputMode, AsyncRetryStrategy<OUT> asyncRetryStrategy, ProcessingTimeService processingTimeService, MailboxExecutor mailboxExecutor)
AsyncWaitOperatorFactory(AsyncFunction<IN,OUT> asyncFunction, long timeout, int capacity, AsyncDataStream.OutputMode outputMode)
AsyncWaitOperatorFactory(AsyncFunction<IN,OUT> asyncFunction, long timeout, int capacity, AsyncDataStream.OutputMode outputMode, AsyncRetryStrategy<OUT> asyncRetryStrategy)

Uses of AsyncFunction in org.apache.flink.table.planner.codegen

Methods in org.apache.flink.table.planner.codegen that return types with arguments of type AsyncFunction

Modifier and Type	Method and Description
static GeneratedFunction<AsyncFunction<RowData,RowData>>	AsyncCodeGenerator.generateFunction(String name, RowType inputType, RowType returnType, List<org.apache.calcite.rex.RexNode> calcProjection, boolean retainHeader, ReadableConfig tableConfig, ClassLoader classLoader) Creates a generated function which produces an AsyncFunction which executes the calc projections.

Uses of AsyncFunction in org.apache.flink.table.runtime.operators.calc.async

Classes in org.apache.flink.table.runtime.operators.calc.async that implement AsyncFunction

Modifier and Type	Class and Description
class	AsyncFunctionRunner Async function runner for AsyncScalarFunction, which takes the generated function, instantiates it, and then calls its lifecycle methods.

Constructor parameters in org.apache.flink.table.runtime.operators.calc.async with type arguments of type AsyncFunction

Constructor and Description
AsyncFunctionRunner(GeneratedFunction<AsyncFunction<RowData,RowData>> generatedFetcher)

Uses of AsyncFunction in org.apache.flink.table.runtime.operators.join.lookup

Classes in org.apache.flink.table.runtime.operators.join.lookup that implement AsyncFunction

Modifier and Type	Class and Description
class	AsyncLookupJoinRunner The async join runner to lookup the dimension table.
class	AsyncLookupJoinWithCalcRunner The async join runner with an additional calculate function on the dimension table.

Constructor parameters in org.apache.flink.table.runtime.operators.join.lookup with type arguments of type AsyncFunction

Constructor and Description
AsyncLookupJoinRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher, DataStructureConverter<RowData,Object> fetcherConverter, GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)
AsyncLookupJoinWithCalcRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher, DataStructureConverter<RowData,Object> fetcherConverter, GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc, GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)