pyflink.datastream.async_data_stream.AsyncDataStream.unordered_wait_with_retry

static AsyncDataStream.unordered_wait_with_retry(data_stream: DataStream, async_function: AsyncFunction, timeout: Time, async_retry_strategy: AsyncRetryStrategy, capacity: int = 100, output_type: TypeInformation | None = None) → DataStream

Adds an async function with an AsyncRetryStrategy to support retry of AsyncFunction to the data stream. The order of output stream records may be reordered.

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.