pyflink.datastream.async_data_stream.AsyncDataStream.unordered_wait

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

Adds an async function 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.

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

• output_type – The output data type.

Returns

The transformed DataStream.