org.apache.hadoop.chukwa.extraction.hbase

Class AbstractProcessor

java.lang.Object

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

Direct Known Subclasses:

DefaultProcessor, HadoopMetricsProcessor, SystemMetrics

public abstract class AbstractProcessor
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected int	entryCount
protected byte[]	key
protected String	primaryKeyHelper
protected String	sourceHelper

Constructor Summary

Constructors

Constructor and Description
AbstractProcessor()

Method Summary

Modifier and Type	Method and Description
protected void	addMeta()
void	addRecord(long time, String metric, String source, byte[] value, ArrayList<org.apache.hadoop.hbase.client.Put> output) Generic metric function to add a metric to HBase with full primary key and source computed.
void	addRecord(String metric, byte[] value) Generic function to add a metric to HBase metric table, this function assumes "time" and "source" have been defined and will construct primaryKey only, without recompute time and source md5.
void	addRecord(String primaryKey, String value)
protected abstract void	parse(byte[] recordEntry)
void	process(Chunk chunk, ArrayList<org.apache.hadoop.hbase.client.Put> output, Reporter reporter) Process a chunk to store in HBase.

Methods inherited from class java.lang.Object

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

Field Detail

entryCount

protected int entryCount

primaryKeyHelper

protected String primaryKeyHelper

sourceHelper

protected String sourceHelper

key

protected byte[] key

Constructor Detail

AbstractProcessor

public AbstractProcessor()
                  throws NoSuchAlgorithmException

Throws:

NoSuchAlgorithmException

Method Detail

parse

protected abstract void parse(byte[] recordEntry)
                       throws Throwable

Throws:

Throwable

addRecord

public void addRecord(long time,
                      String metric,
                      String source,
                      byte[] value,
                      ArrayList<org.apache.hadoop.hbase.client.Put> output)

Generic metric function to add a metric to HBase with full primary key and source computed.

Parameters:

time -

metric -

source -

value -

output -

addRecord

public void addRecord(String primaryKey,
                      String value)

addRecord

public void addRecord(String metric,
                      byte[] value)

Generic function to add a metric to HBase metric table, this function assumes "time" and "source" have been defined and will construct primaryKey only, without recompute time and source md5.

Parameters:

metric -

value -

process

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

Process a chunk to store in HBase.

Parameters:

chunk -

output -

reporter -

Throws:

Throwable

addMeta

protected void addMeta()