pyflink.datastream.functions.AsyncFunction.async_invoke# abstract async AsyncFunction.async_invoke(value: IN) → List[OUT][source]# 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.
