public final class FaultTolerance extends Object implements ExceptionHandler
Modifier and Type | Field and Description |
---|---|
static String |
IS_IGNORING_RECOVERABLE_EXCEPTIONS |
static String |
IS_PRODUCTION_MODE |
static String |
RECOVERABLE_EXCEPTION_CLASSES |
Constructor and Description |
---|
FaultTolerance(boolean isProductionMode,
boolean isIgnoringRecoverableExceptions) |
FaultTolerance(boolean isProductionMode,
boolean isIgnoringRecoverableExceptions,
String recoverableExceptionClassNames) |
Modifier and Type | Method and Description |
---|---|
void |
handleException(Throwable t,
Record record)
Handle the given exception resulting from the given input record (the record can be null)
|
public static final String IS_PRODUCTION_MODE
public static final String IS_IGNORING_RECOVERABLE_EXCEPTIONS
public static final String RECOVERABLE_EXCEPTION_CLASSES
public FaultTolerance(boolean isProductionMode, boolean isIgnoringRecoverableExceptions)
public FaultTolerance(boolean isProductionMode, boolean isIgnoringRecoverableExceptions, String recoverableExceptionClassNames)
public void handleException(Throwable t, Record record)
ExceptionHandler
handleException
in interface ExceptionHandler
Copyright © 2013–2015. All rights reserved.