org.apache.hadoop.chukwa.extraction.hbase

Class ChukwaMetricsProcessor

java.lang.Object

org.apache.hadoop.chukwa.extraction.hbase.AbstractProcessor

org.apache.hadoop.chukwa.extraction.hbase.HadoopMetricsProcessor

org.apache.hadoop.chukwa.extraction.hbase.ChukwaMetricsProcessor

public class ChukwaMetricsProcessor
extends HadoopMetricsProcessor

Constructor Summary

Constructors

Constructor and Description
ChukwaMetricsProcessor()

Method Summary

Modifier and Type	Method and Description
void	process(Chunk chunk, ArrayList<org.apache.hadoop.hbase.client.Put> output, Reporter reporter) Process cluster name and store in HBase.

Methods inherited from class org.apache.hadoop.chukwa.extraction.hbase.AbstractProcessor

addRecord, addRecord, addRecord

Methods inherited from class java.lang.Object

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

Constructor Detail

ChukwaMetricsProcessor

public ChukwaMetricsProcessor()
                       throws NoSuchAlgorithmException

Throws:

NoSuchAlgorithmException

Method Detail

process

public void process(Chunk chunk,
                    ArrayList<org.apache.hadoop.hbase.client.Put> output,
                    Reporter reporter)
             throws Throwable

Process cluster name and store in HBase.

Overrides:

process in class AbstractProcessor

Parameters:

chunk - is a Chukwa data chunk

output - is a list of Put operations

reporter - is progress reporter

Throws:

Throwable - if unable to send data