org.apache.hadoop.hive.ql.stats
Class CounterStatsAggregator

java.lang.Object
  org.apache.hadoop.hive.ql.stats.CounterStatsAggregator

All Implemented Interfaces:

StatsAggregator, StatsCollectionTaskIndependent

public class CounterStatsAggregator
extends Object
implements StatsAggregator, StatsCollectionTaskIndependent

Constructor Summary

CounterStatsAggregator()

Method Summary

String	aggregateStats(String counterGrpName, String statType) This method aggregates a given statistic from all tasks (partial stats).
boolean	cleanUp(String keyPrefix) This method is called after all statistics have been aggregated.
boolean	closeConnection() This method closes the connection to the temporary storage.
boolean	connect(org.apache.hadoop.conf.Configuration hconf, Task sourceTask) This method connects to the temporary storage.

Methods inherited from class java.lang.Object

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

Constructor Detail

CounterStatsAggregator

public CounterStatsAggregator()

Method Detail

connect

public boolean connect(org.apache.hadoop.conf.Configuration hconf,
                       Task sourceTask)

Description copied from interface: StatsAggregator

This method connects to the temporary storage.

Specified by:

connect in interface StatsAggregator

Parameters:

hconf - HiveConf that contains the connection parameters.

Returns:

true if connection is successful, false otherwise.

aggregateStats

public String aggregateStats(String counterGrpName,
                             String statType)

Description copied from interface: StatsAggregator

This method aggregates a given statistic from all tasks (partial stats). After aggregation, this method also automatically removes all records that have been aggregated.

Specified by:

aggregateStats in interface StatsAggregator

Parameters:

counterGrpName - a prefix of the keys used in StatsPublisher to publish stats. Any rows that starts with the same prefix will be aggregated. For example, if the StatsPublisher uses the following compound key to publish stats: the output directory name (unique per FileSinkOperator) + the partition specs (only for dynamic partitions) + taskID (last component of task file) The keyPrefix for aggregation could be first 2 components. This will aggregates stats across all tasks for each partition.

statType - a string noting the key to be published. Ex: "numRows".

Returns:

a string representation of a long value, null if there are any error/exception.

closeConnection

public boolean closeConnection()

Description copied from interface: StatsAggregator

This method closes the connection to the temporary storage.

Specified by:

closeConnection in interface StatsAggregator

Returns:

true if close connection is successful, false otherwise.

cleanUp

public boolean cleanUp(String keyPrefix)

Description copied from interface: StatsAggregator

This method is called after all statistics have been aggregated. Since we support multiple statistics, we do not perform automatic cleanup after aggregation. After this method is called, closeConnection must be called as well. This method is also used to clear the temporary statistics that have been published without being aggregated. Typically this happens when a job fails, or is forcibly stopped after publishing some statistics.

Specified by:

cleanUp in interface StatsAggregator

Parameters:

keyPrefix - a prefix of the keys used in StatsPublisher to publish stats. It is the same as the first parameter in aggregateStats().

Returns:

true if cleanup is successful, false otherwise.