org.apache.pig

Class CounterBasedErrorHandler

java.lang.Object

org.apache.pig.CounterBasedErrorHandler

All Implemented Interfaces:

ErrorHandler

public class CounterBasedErrorHandler
extends java.lang.Object
implements ErrorHandler

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ERROR_COUNT
static java.lang.String	ERROR_HANDLER_COUNTER_GROUP
static java.lang.String	RECORD_COUNT

Constructor Summary

Constructors

Constructor and Description
CounterBasedErrorHandler()

Method Summary

Modifier and Type	Method and Description
long	getRecordCount(java.lang.String signature)
void	onError(java.lang.String uniqueSignature, java.lang.Exception e) Method invoked when an error occurs processing of tuple
void	onSuccess(java.lang.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

ERROR_HANDLER_COUNTER_GROUP

public static final java.lang.String ERROR_HANDLER_COUNTER_GROUP

See Also:

Constant Field Values

ERROR_COUNT

public static final java.lang.String ERROR_COUNT

See Also:

Constant Field Values

RECORD_COUNT

public static final java.lang.String RECORD_COUNT

See Also:

Constant Field Values

Constructor Detail

CounterBasedErrorHandler

public CounterBasedErrorHandler()

Method Detail

onSuccess

public void onSuccess(java.lang.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(java.lang.String uniqueSignature,
                    java.lang.Exception e)

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

getRecordCount

public long getRecordCount(java.lang.String signature)