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

Packages that use AsyncRetryStrategy

Package	Description
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.util.retryable

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

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

Modifier and Type	Method	Description
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.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 AsyncRetryStrategy in org.apache.flink.streaming.api.operators.async

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

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, AsyncRetryStrategy<OUT> asyncRetryStrategy)

Uses of AsyncRetryStrategy in org.apache.flink.streaming.util.retryable

Classes in org.apache.flink.streaming.util.retryable that implement AsyncRetryStrategy

Modifier and Type	Class	Description
static class	AsyncRetryStrategies.ExponentialBackoffDelayRetryStrategy<OUT>	ExponentialBackoffDelayRetryStrategy.
static class	AsyncRetryStrategies.FixedDelayRetryStrategy<OUT>	FixedDelayRetryStrategy.