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

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	Description
static <IN,OUT> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<OUT>	AsyncDataStream.orderedWait(org.apache.flink.streaming.api.datastream.DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit)	Adds an AsyncWaitOperator.
static <IN,OUT> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<OUT>	AsyncDataStream.orderedWait(org.apache.flink.streaming.api.datastream.DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit, int capacity)	Adds an AsyncWaitOperator.
static <IN,OUT> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<OUT>	AsyncDataStream.orderedWaitWithRetry(org.apache.flink.streaming.api.datastream.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> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<OUT>	AsyncDataStream.orderedWaitWithRetry(org.apache.flink.streaming.api.datastream.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> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<OUT>	AsyncDataStream.unorderedWait(org.apache.flink.streaming.api.datastream.DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit)	Adds an AsyncWaitOperator.
static <IN,OUT> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<OUT>	AsyncDataStream.unorderedWait(org.apache.flink.streaming.api.datastream.DataStream<IN> in, AsyncFunction<IN,OUT> func, long timeout, TimeUnit timeUnit, int capacity)	Adds an AsyncWaitOperator.
static <IN,OUT> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<OUT>	AsyncDataStream.unorderedWaitWithRetry(org.apache.flink.streaming.api.datastream.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> org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<OUT>	AsyncDataStream.unorderedWaitWithRetry(org.apache.flink.streaming.api.datastream.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.

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	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	Description
AsyncWaitOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT> parameters, AsyncFunction<IN,OUT> asyncFunction, long timeout, int capacity, AsyncDataStream.OutputMode outputMode, AsyncRetryStrategy<OUT> asyncRetryStrategy, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService, org.apache.flink.api.common.operators.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)