Uses of Class
org.apache.flink.connector.base.sink.throwable.FatalExceptionClassifier
-
Packages that use FatalExceptionClassifier Package Description org.apache.flink.connector.base.sink.throwable org.apache.flink.connector.base.sink.writer -
-
Uses of FatalExceptionClassifier in org.apache.flink.connector.base.sink.throwable
Methods in org.apache.flink.connector.base.sink.throwable that return FatalExceptionClassifier Modifier and Type Method Description static FatalExceptionClassifierFatalExceptionClassifier. createChain(FatalExceptionClassifier... classifiers)static FatalExceptionClassifierFatalExceptionClassifier. withRootCauseOfType(Class<? extends Throwable> type, java.util.function.Function<Throwable,Exception> mapper)Methods in org.apache.flink.connector.base.sink.throwable with parameters of type FatalExceptionClassifier Modifier and Type Method Description static FatalExceptionClassifierFatalExceptionClassifier. createChain(FatalExceptionClassifier... classifiers) -
Uses of FatalExceptionClassifier in org.apache.flink.connector.base.sink.writer
Methods in org.apache.flink.connector.base.sink.writer that return FatalExceptionClassifier Modifier and Type Method Description static FatalExceptionClassifierAsyncSinkFatalExceptionClassifiers. getInterruptedExceptionClassifier()
-