com.datastax.oss.dsbulk.workflow.api.utils

Class ThrowableUtils

java.lang.Object

com.datastax.oss.dsbulk.workflow.api.utils.ThrowableUtils

public class ThrowableUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
ThrowableUtils()

Method Summary

Modifier and Type	Method and Description
static String	getSanitizedErrorMessage(Throwable error) Returns a sanitized, prettified error message for the given throwable.
static String	getSanitizedErrorMessage(Throwable error, Predicate<Throwable> filter, int indentation) Returns a sanitized, prettified error message for the given throwable.
static boolean	isInterrupted(Throwable throwable) Returns true when the given throwable, its cause, or any of its suppressed errors is an InterruptedException or any of its common variants.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThrowableUtils

public ThrowableUtils()

Method Detail

isInterrupted

public static boolean isInterrupted(@NonNull
                                    Throwable throwable)

Returns true when the given throwable, its cause, or any of its suppressed errors is an InterruptedException or any of its common variants. Returns false otherwise.

This is mainly motivated by the fact the DSBulk engine uses the Reactor framework, which sometimes wraps InterruptedException inside other exceptions, making it hard to detect when the operation has been interrupted.

Parameters:

throwable - The throwable to inspect.

Returns:

true if interrupted, false otherwise.

getSanitizedErrorMessage

@NonNull
public static String getSanitizedErrorMessage(@NonNull
                                                       Throwable error)

Returns a sanitized, prettified error message for the given throwable. The message is suitable for printing to the console and gives the user the best possible knowledge of the root cause.

Parameters:

error - The throwable to extract a sanitized message from.

Returns:

The sanitized message.

getSanitizedErrorMessage

@NonNull
public static String getSanitizedErrorMessage(@NonNull
                                                       Throwable error,
                                                       @NonNull
                                                       Predicate<Throwable> filter,
                                                       int indentation)

Returns a sanitized, prettified error message for the given throwable. The message is suitable for printing to the console and gives the user the best possible knowledge of the root cause.

Parameters:

error - The throwable to extract a sanitized message from.

filter - A filter to eliminate unwanted/unnecessary errors.

indentation - The number of spaces to add when indenting a new line of message.

Returns:

The sanitized message.