org.apache.pig.tools.pigstats

Class PigStatsUtil

java.lang.Object

org.apache.pig.tools.pigstats.PigStatsUtil

Direct Known Subclasses:

MRPigStatsUtil

public class PigStatsUtil
extends java.lang.Object

A utility class for Pig Statistics

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	FS_COUNTER_GROUP Deprecated. use MRPigStatsUtil.FS_COUNTER_GROUP instead.
static java.lang.String	HDFS_BYTES_READ
static java.lang.String	HDFS_BYTES_WRITTEN
static java.lang.String	MAP_INPUT_RECORDS
static java.lang.String	MAP_OUTPUT_RECORDS
static java.lang.String	MULTI_INPUTS_COUNTER_GROUP
static java.lang.String	MULTI_INPUTS_RECORD_COUNTER
static java.lang.String	MULTI_STORE_COUNTER_GROUP
static java.lang.String	MULTI_STORE_RECORD_COUNTER
static java.lang.String	REDUCE_INPUT_RECORDS
static java.lang.String	REDUCE_OUTPUT_RECORDS
static java.lang.String	TASK_COUNTER_GROUP Deprecated. use MRPigStatsUtil.TASK_COUNTER_GROUP instead.

Constructor Summary

Constructors

Constructor and Description
PigStatsUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static PigStats	getEmptyPigStats() Deprecated.
static java.lang.String	getMultiInputsCounterName(java.lang.String fname, int index) Returns the counter name for the given input file name
static java.lang.String	getMultiStoreCounterName(POStore store) Returns the counter name for the given POStore
static PigStats	getPigStats(int code) Returns the PigStats with the given return code
static boolean	isTempFile(java.lang.String fileName)
static void	setErrorCode(int code)
static void	setErrorMessage(java.lang.String msg)
static void	setErrorThrowable(java.lang.Throwable t)
static void	setStatsMap(java.util.Map<java.lang.String,java.util.List<PigStats>> statsMap)

Methods inherited from class java.lang.Object

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

Field Detail

MAP_INPUT_RECORDS

public static final java.lang.String MAP_INPUT_RECORDS

See Also:

Constant Field Values

MAP_OUTPUT_RECORDS

public static final java.lang.String MAP_OUTPUT_RECORDS

See Also:

Constant Field Values

REDUCE_INPUT_RECORDS

public static final java.lang.String REDUCE_INPUT_RECORDS

See Also:

Constant Field Values

REDUCE_OUTPUT_RECORDS

public static final java.lang.String REDUCE_OUTPUT_RECORDS

See Also:

Constant Field Values

HDFS_BYTES_WRITTEN

public static final java.lang.String HDFS_BYTES_WRITTEN

See Also:

Constant Field Values

HDFS_BYTES_READ

public static final java.lang.String HDFS_BYTES_READ

See Also:

Constant Field Values

MULTI_INPUTS_RECORD_COUNTER

public static final java.lang.String MULTI_INPUTS_RECORD_COUNTER

See Also:

Constant Field Values

MULTI_INPUTS_COUNTER_GROUP

public static final java.lang.String MULTI_INPUTS_COUNTER_GROUP

See Also:

Constant Field Values

MULTI_STORE_RECORD_COUNTER

public static final java.lang.String MULTI_STORE_RECORD_COUNTER

See Also:

Constant Field Values

MULTI_STORE_COUNTER_GROUP

public static final java.lang.String MULTI_STORE_COUNTER_GROUP

See Also:

Constant Field Values

TASK_COUNTER_GROUP

@Deprecated
public static final java.lang.String TASK_COUNTER_GROUP

Deprecated. use MRPigStatsUtil.TASK_COUNTER_GROUP instead.

See Also:

Constant Field Values

FS_COUNTER_GROUP

@Deprecated
public static final java.lang.String FS_COUNTER_GROUP

Deprecated. use MRPigStatsUtil.FS_COUNTER_GROUP instead.

Constructor Detail

PigStatsUtil

public PigStatsUtil()

Method Detail

getEmptyPigStats

@Deprecated
public static PigStats getEmptyPigStats()

Deprecated.

Returns an empty PigStats object Use of this method is not advised as it will return the MR execution engine version of PigStats by default, and is not necessarily empty depending on the timing.

Returns:

an empty PigStats object

getPigStats

public static PigStats getPigStats(int code)

Returns the PigStats with the given return code

Parameters:

code - the return code

Returns:

the PigStats with the given return code

setErrorMessage

public static void setErrorMessage(java.lang.String msg)

setErrorCode

public static void setErrorCode(int code)

setErrorThrowable

public static void setErrorThrowable(java.lang.Throwable t)

isTempFile

public static boolean isTempFile(java.lang.String fileName)

setStatsMap

public static void setStatsMap(java.util.Map<java.lang.String,java.util.List<PigStats>> statsMap)

getMultiInputsCounterName

public static java.lang.String getMultiInputsCounterName(java.lang.String fname,
                                         int index)

Returns the counter name for the given input file name

Parameters:

fname - the input file name

Returns:

the counter name

getMultiStoreCounterName

public static java.lang.String getMultiStoreCounterName(POStore store)

Returns the counter name for the given POStore

Parameters:

store - the POStore

Returns:

the counter name