pyflink.datastream.async_data_stream.AsyncDataStream.ordered_wait_with_retry

static AsyncDataStream.ordered_wait_with_retry(data_stream: pyflink.datastream.data_stream.DataStream, async_function: pyflink.datastream.functions.AsyncFunction, timeout: pyflink.common.time.Time, async_retry_strategy: pyflink.datastream.functions.AsyncRetryStrategy, capacity: int = 100, output_type: Optional[pyflink.common.typeinfo.TypeInformation] = None) → pyflink.datastream.data_stream.DataStream

Adds an async function with an AsyncRetryStrategy to support retry of AsyncFunction to the data stream. The order to process input records is guaranteed to be the same as input ones.

Parameters

• data_stream – The input data stream.

• async_function – The async function.

• timeout – The timeout for the asynchronous operation to complete.

• async_retry_strategy – The strategy of reattempt async i/o operation that can be triggered

• capacity – The max number of async i/o operation that can be triggered.

• output_type – The output data type.

Returns

The transformed DataStream.