org.apache.flink.streaming.api.functions.async

Interface AsyncRetryPredicate<OUT>

@PublicEvolving
public interface AsyncRetryPredicate<OUT>

Interface encapsulates an asynchronous retry predicate.

Method Summary

Modifier and Type	Method and Description
Optional<java.util.function.Predicate<Throwable>>	exceptionPredicate() An Optional Java that defines a condition on asyncFunction's exception which will trigger a later reattempt operation, will be called before user's ResultFuture#completeExceptionally.
Optional<java.util.function.Predicate<Collection<OUT>>>	resultPredicate() An Optional Java that defines a condition on asyncFunction's future result which will trigger a later reattempt operation, will be called before user's ResultFuture#complete.

Method Detail

resultPredicate

Optional<java.util.function.Predicate<Collection<OUT>>> resultPredicate()

An Optional Java that defines a condition on asyncFunction's future result which will trigger a later reattempt operation, will be called before user's ResultFuture#complete.

Returns:

predicate on result of Collection

exceptionPredicate

Optional<java.util.function.Predicate<Throwable>> exceptionPredicate()

An Optional Java that defines a condition on asyncFunction's exception which will trigger a later reattempt operation, will be called before user's ResultFuture#completeExceptionally.

Returns:

predicate on Throwable exception