org.apache.flink.connector.aws.sink.throwable

Class AWSExceptionHandler

java.lang.Object

org.apache.flink.connector.aws.sink.throwable.AWSExceptionHandler

@Internal
public class AWSExceptionHandler
extends Object

Class to provide improved semantics over FatalExceptionClassifier.isFatal(Throwable, Consumer). FatalExceptionClassifier.isFatal(Throwable, Consumer) returns `false` for a fatal exception and `true` for a non-fatal exception.

Method Summary

Modifier and Type	Method and Description
boolean	consumeIfFatal(Throwable t, java.util.function.Consumer<Exception> consumer) Passes a given Throwable t to a given Consumer consumer if the throwable is fatal.
static AWSExceptionHandler	withClassifier(org.apache.flink.connector.base.sink.throwable.FatalExceptionClassifier classifier)

Methods inherited from class java.lang.Object

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

Method Detail

withClassifier

public static AWSExceptionHandler withClassifier(org.apache.flink.connector.base.sink.throwable.FatalExceptionClassifier classifier)

consumeIfFatal

public boolean consumeIfFatal(Throwable t,
                              java.util.function.Consumer<Exception> consumer)

Passes a given Throwable t to a given Consumer consumer if the throwable is fatal. Returns `true` if the Throwable has been passed to the Consumer (i.e. it is fatal) and `false` otherwise.

Parameters:

t - a Throwable

consumer - a Consumer to call if the passed throwable t is fatal.

Returns:

`true` if t is fatal, `false` otherwise.