pyflink.datastream.async_data_stream.AsyncDataStream.ordered_wait

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

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

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

• output_type – The output data type.

Returns:

The transformed DataStream.