org.apache.pig

Class CounterBasedErrorHandler

java.lang.Object

org.apache.pig.CounterBasedErrorHandler

All Implemented Interfaces:

ErrorHandler

public class CounterBasedErrorHandler
extends Object
implements ErrorHandler

Field Summary

Fields

Modifier and Type	Field and Description
static String	STORER_ERROR_COUNT
static String	STORER_ERROR_HANDLER_COUNTER_GROUP
static String	STORER_RECORD_COUNT

Constructor Summary

Constructors

Constructor and Description
CounterBasedErrorHandler()

Method Summary

Modifier and Type	Method and Description
long	getRecordCount(String storeSignature)
void	onError(String uniqueSignature, Exception e, Tuple inputTuple) Method invoked when an error occurs processing of tuple
void	onSuccess(String uniqueSignature) Method invoked on success processing of tuple

Methods inherited from class java.lang.Object

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

Field Detail

STORER_ERROR_HANDLER_COUNTER_GROUP

public static final String STORER_ERROR_HANDLER_COUNTER_GROUP

See Also:

Constant Field Values

STORER_ERROR_COUNT

public static final String STORER_ERROR_COUNT

See Also:

Constant Field Values

STORER_RECORD_COUNT

public static final String STORER_RECORD_COUNT

See Also:

Constant Field Values

Constructor Detail

CounterBasedErrorHandler

public CounterBasedErrorHandler()

Method Detail

onSuccess

public void onSuccess(String uniqueSignature)

Description copied from interface: ErrorHandler

Method invoked on success processing of tuple

Specified by:

onSuccess in interface ErrorHandler

Parameters:

uniqueSignature - a unique signature to identify the operator

onError

public void onError(String uniqueSignature,
                    Exception e,
                    Tuple inputTuple)

Description copied from interface: ErrorHandler

Method invoked when an error occurs processing of tuple

Specified by:

onError in interface ErrorHandler

Parameters:

uniqueSignature - a unique signature to identify the operator

e - Exception encountered while processing input

inputTuple - the tuple to store.

getRecordCount

public long getRecordCount(String storeSignature)