Package org.apache.flink.streaming.util.retryable

Class RetryPredicates

java.lang.Object

org.apache.flink.streaming.util.retryable.RetryPredicates

public class RetryPredicates
extends Object

Utility class to create concrete retry predicates.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.streaming.util.retryable.RetryPredicates.EmptyResultPredicate	EMPTY_RESULT_PREDICATE	A predicate matches empty result which means an empty Collection.
static org.apache.flink.streaming.util.retryable.RetryPredicates.HasExceptionPredicate	HAS_EXCEPTION_PREDICATE	A predicate matches any exception which means a non-nullThrowable.

Constructor Summary

Constructors

Constructor	Description
RetryPredicates()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.streaming.util.retryable.RetryPredicates.ExceptionTypePredicate	createExceptionTypePredicate(Class<? extends Throwable> exceptionClass)	Creates a predicate on given exception type.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

EMPTY_RESULT_PREDICATE

public static final org.apache.flink.streaming.util.retryable.RetryPredicates.EmptyResultPredicate EMPTY_RESULT_PREDICATE

A predicate matches empty result which means an empty Collection.

HAS_EXCEPTION_PREDICATE

public static final org.apache.flink.streaming.util.retryable.RetryPredicates.HasExceptionPredicate HAS_EXCEPTION_PREDICATE

A predicate matches any exception which means a non-nullThrowable.

Constructor Detail

RetryPredicates

public RetryPredicates()

Method Detail

createExceptionTypePredicate

public static org.apache.flink.streaming.util.retryable.RetryPredicates.ExceptionTypePredicate createExceptionTypePredicate(@Nonnull
                                                                                                                            Class<? extends Throwable> exceptionClass)

Creates a predicate on given exception type.

Parameters:

exceptionClass -

Returns:

predicate on exception type.