org.apache.hadoop.chukwa.datacollection.writer.hbase

Class HBaseWriter

java.lang.Object

org.apache.hadoop.chukwa.datacollection.writer.PipelineableWriter

org.apache.hadoop.chukwa.datacollection.writer.hbase.HBaseWriter

All Implemented Interfaces:

ChukwaWriter

public class HBaseWriter
extends PipelineableWriter

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.chukwa.datacollection.writer.ChukwaWriter

ChukwaWriter.COMMIT_PENDING, ChukwaWriter.CommitStatus

Field Summary

Fields inherited from class org.apache.hadoop.chukwa.datacollection.writer.PipelineableWriter

next

Fields inherited from interface org.apache.hadoop.chukwa.datacollection.writer.ChukwaWriter

COMMIT_FAIL, COMMIT_OK

Constructor Summary

Constructors

Constructor and Description
HBaseWriter()
HBaseWriter(boolean reportStats)
HBaseWriter(ChukwaConfiguration conf, org.apache.hadoop.conf.Configuration hconf)

Method Summary

Methods

Modifier and Type	Method and Description
ChukwaWriter.CommitStatus	add(List<Chunk> chunks) Called repeatedly with data that should be serialized.
void	close() Called once, indicating that the writer should close files and prepare to exit.
String	findHBaseColumnFamilyName(String dataType)
Annotation.Table	findHBaseTable(String dataType)
void	init(org.apache.hadoop.conf.Configuration conf) Called once to initialize this writer.

Methods inherited from class org.apache.hadoop.chukwa.datacollection.writer.PipelineableWriter

setNextStage

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseWriter

public HBaseWriter()
            throws IOException

Throws:

IOException

HBaseWriter

public HBaseWriter(boolean reportStats)
            throws IOException

Throws:

IOException

HBaseWriter

public HBaseWriter(ChukwaConfiguration conf,
           org.apache.hadoop.conf.Configuration hconf)
            throws IOException

Throws:

IOException

Method Detail

close

public void close()

Description copied from interface: ChukwaWriter

Called once, indicating that the writer should close files and prepare to exit.

init

public void init(org.apache.hadoop.conf.Configuration conf)
          throws WriterException

Description copied from interface: ChukwaWriter

Called once to initialize this writer.

Throws:

WriterException

add

public ChukwaWriter.CommitStatus add(List<Chunk> chunks)
                              throws WriterException

Description copied from interface: ChukwaWriter

Called repeatedly with data that should be serialized. Subclasses may assume that init() will be called before any calls to add(), and that add() won't be called after close().

Specified by:

add in interface ChukwaWriter

Overrides:

add in class PipelineableWriter

Returns:

Throws:

WriterException

findHBaseTable

public Annotation.Table findHBaseTable(String dataType)
                                throws UnknownRecordTypeException

Throws:

UnknownRecordTypeException

findHBaseColumnFamilyName

public String findHBaseColumnFamilyName(String dataType)
                                 throws UnknownRecordTypeException

Throws:

UnknownRecordTypeException