org.elasticsearch.hadoop.handler.impl

Class DropAndLog<I extends Exceptional,O,C extends ErrorCollector<O>>

java.lang.Object

org.elasticsearch.hadoop.handler.impl.DropAndLog<I,O,C>

All Implemented Interfaces:

ErrorHandler<I,O,C>

public class DropAndLog<I extends Exceptional,O,C extends ErrorCollector<O>>
extends java.lang.Object
implements ErrorHandler<I,O,C>

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONF_LOGGER_CLASS
static java.lang.String	CONF_LOGGER_LEVEL
static java.lang.String	CONF_LOGGER_NAME

Constructor Summary

Constructors

Constructor and Description
DropAndLog(LogRenderer<I> logLineMaker)

Method Summary

Modifier and Type	Method and Description
void	close() Called at the close of the connector to clean up any internal resources.
static <I extends Exceptional,O,C extends ErrorCollector<O>> DropAndLog<I,O,C>	create(LogRenderer<I> logLineMaker)
void	init(java.util.Properties properties) Called at the handler creation time to initialize any internal state or resources.
HandlerResult	onError(I entry, C collector) Called when an exception or failure occurs in a part of the connector.

Methods inherited from class java.lang.Object

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

Field Detail

CONF_LOGGER_NAME

public static final java.lang.String CONF_LOGGER_NAME

See Also:

Constant Field Values

CONF_LOGGER_CLASS

public static final java.lang.String CONF_LOGGER_CLASS

See Also:

Constant Field Values

CONF_LOGGER_LEVEL

public static final java.lang.String CONF_LOGGER_LEVEL

See Also:

Constant Field Values

Constructor Detail

DropAndLog

public DropAndLog(LogRenderer<I> logLineMaker)

Method Detail

create

public static <I extends Exceptional,O,C extends ErrorCollector<O>> DropAndLog<I,O,C> create(LogRenderer<I> logLineMaker)

init

public void init(java.util.Properties properties)

Description copied from interface: ErrorHandler

Called at the handler creation time to initialize any internal state or resources.

Specified by:

init in interface ErrorHandler<I extends Exceptional,O,C extends ErrorCollector<O>>

Parameters:

properties - Properties for this handler with handler name prefix stripped away.

onError

public HandlerResult onError(I entry,
                             C collector)
                      throws java.lang.Exception

Description copied from interface: ErrorHandler

Called when an exception or failure occurs in a part of the connector.

Specified by:

onError in interface ErrorHandler<I extends Exceptional,O,C extends ErrorCollector<O>>

Parameters:

entry - information about the failure, normally includes operational data and error information

collector - handler for accepting user reactions to the failure, like retrying with modified parameters

Returns:

An enum that describes the handler's result, either that it handled the error or if the error should be passed on to the next handler.

Throws:

java.lang.Exception - In the event that the current failure should not be handled, and should halt the connector processing.

close

public void close()

Description copied from interface: ErrorHandler

Called at the close of the connector to clean up any internal resources.

Specified by:

close in interface ErrorHandler<I extends Exceptional,O,C extends ErrorCollector<O>>