pyflink.datastream.async_data_stream.AsyncDataStream.unordered_wait_with_retry

static AsyncDataStream.unordered_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 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.