pyflink.datastream.functions.AsyncFunction.async_invoke

abstract async AsyncFunction.async_invoke(value: pyflink.datastream.functions.IN) → List[pyflink.datastream.functions.OUT]

Trigger async operation for each stream input. In case of a user code error. You can raise an exception to make the task fail and trigger fail-over process.

Parameters

value – Input element coming from an upstream task.