Package org.apache.flink.table.runtime.operators.calc.async

Class Summary

Class	Description
AsyncFunctionRunner	Async function runner for AsyncScalarFunction, which takes the generated function, instantiates it, and then calls its lifecycle methods.
DelegatingAsyncResultFuture	Inspired by DelegatingResultFuture for AsyncScalarFunction.
RetryPredicates	Contains retry predicates used to determine if a result or error should result in a retry.
RetryPredicates.AnyExceptionStrategy	Returns true for any exception.
RetryPredicates.EmptyResponseResultStrategy	Returns true if the response is null or empty.