pyflink.datastream.functions.AsyncFunction

class AsyncFunction

A function to trigger Async I/O operation.

For each #async_invoke, an async io operation can be triggered. For each async operation, its context is stored in the operator immediately after invoking #async_invoke, avoiding blocking for each stream input as long as the internal buffer is not full.

Methods

async_invoke(value)	Trigger async operation for each stream input.
close()
open(runtime_context)
timeout(value)	In case async_invoke() timeout occurred.