org.apache.hadoop.hive.hbase

Class HBaseStatsAggregator

java.lang.Object

org.apache.hadoop.hive.hbase.HBaseStatsAggregator

All Implemented Interfaces:

StatsAggregator

public class HBaseStatsAggregator
extends Object
implements StatsAggregator

A class that implements the StatsAggregator interface through HBase.

Constructor Summary

Constructors

Constructor and Description
HBaseStatsAggregator()

Method Summary

Methods

Modifier and Type	Method and Description
String	aggregateStats(String rowID, String key) Aggregates temporary stats from HBase;
boolean	cleanUp(String rowID) 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 hiveconf, Task sourceTask) Does the necessary HBase initializations.

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseStatsAggregator

public HBaseStatsAggregator()

Method Detail

connect

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

Does the necessary HBase initializations.

Specified by:

connect in interface StatsAggregator

Parameters:

hiveconf - HiveConf that contains the connection parameters.

Returns:

true if connection is successful, false otherwise.

aggregateStats

public String aggregateStats(String rowID,
                    String key)

Aggregates temporary stats from HBase;

Specified by:

aggregateStats in interface StatsAggregator

Parameters:

rowID - 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.

key - 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 rowID)

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:

rowID - 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.