org.apache.streams.hbase

Class HbasePersistWriter

java.lang.Object

org.apache.streams.hbase.HbasePersistWriter

All Implemented Interfaces:

Closeable, Flushable, Serializable, AutoCloseable, StreamsOperation, StreamsPersistWriter

public class HbasePersistWriter
extends Object
implements StreamsPersistWriter, Flushable, Closeable

HbasePersistWriter writes to hbase.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.hbase.client.HConnection	connection
protected org.apache.hadoop.hbase.HTableDescriptor	descriptor
protected Queue<StreamsDatum>	persistQueue
protected org.apache.hadoop.hbase.client.HTablePool	pool
static String	STREAMS_ID
protected org.apache.hadoop.hbase.client.HTableInterface	table

Constructor Summary

Constructors

Constructor and Description
HbasePersistWriter() HbasePersistWriter constructor - resolve HbaseConfiguration from JVM 'hbase'.
HbasePersistWriter(HbaseConfiguration hbaseConfiguration) HbasePersistWriter constructor - use supplied persistQueue.

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
void	close()
void	flush()
String	getId()
void	prepare(Object configurationObject)
void	write(StreamsDatum streamsDatum)

Methods inherited from class java.lang.Object

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

Field Detail

STREAMS_ID

public static final String STREAMS_ID

See Also:

Constant Field Values

connection

protected org.apache.hadoop.hbase.client.HConnection connection

pool

protected org.apache.hadoop.hbase.client.HTablePool pool

table

protected org.apache.hadoop.hbase.client.HTableInterface table

descriptor

protected org.apache.hadoop.hbase.HTableDescriptor descriptor

persistQueue

protected volatile Queue<StreamsDatum> persistQueue

Constructor Detail

HbasePersistWriter

public HbasePersistWriter()

HbasePersistWriter constructor - resolve HbaseConfiguration from JVM 'hbase'.

HbasePersistWriter

public HbasePersistWriter(HbaseConfiguration hbaseConfiguration)

HbasePersistWriter constructor - use supplied persistQueue.

Parameters:

hbaseConfiguration - HbaseConfiguration

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

write

public void write(StreamsDatum streamsDatum)

Specified by:

write in interface StreamsPersistWriter

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation