Package org.apache.flink.connector.base.sink.throwable

Class FatalExceptionClassifier

java.lang.Object

org.apache.flink.connector.base.sink.throwable.FatalExceptionClassifier

@Internal
public class FatalExceptionClassifier
extends Object

Classifier class for retryable exceptions on request submission failure.

Constructor Summary

Constructors

Constructor	Description
FatalExceptionClassifier(java.util.function.Predicate<Throwable> validator, java.util.function.Function<Throwable,Exception> throwableMapper)

Method Summary

Modifier and Type	Method	Description
static FatalExceptionClassifier	createChain(FatalExceptionClassifier... classifiers)
boolean	isFatal(Throwable err, java.util.function.Consumer<Exception> throwableConsumer)
static FatalExceptionClassifier	withRootCauseOfType(Class<? extends Throwable> type, java.util.function.Function<Throwable,Exception> mapper)

Methods inherited from class java.lang.Object

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

Constructor Detail

FatalExceptionClassifier

public FatalExceptionClassifier(java.util.function.Predicate<Throwable> validator,
                                java.util.function.Function<Throwable,Exception> throwableMapper)

Method Detail

isFatal

public boolean isFatal(Throwable err,
                       java.util.function.Consumer<Exception> throwableConsumer)

withRootCauseOfType

public static FatalExceptionClassifier withRootCauseOfType(Class<? extends Throwable> type,
                                                           java.util.function.Function<Throwable,Exception> mapper)

createChain

public static FatalExceptionClassifier createChain(FatalExceptionClassifier... classifiers)