org.apache.streams.hbase

Class HbasePersistReader

java.lang.Object

org.apache.streams.hbase.HbasePersistReader

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsPersistReader, StreamsProvider

public class HbasePersistReader
extends Object
implements StreamsPersistReader, Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected HbaseConfiguration	config
protected ReadWriteLock	lock
protected Queue<StreamsDatum>	persistQueue
protected Properties	props
protected AtomicBoolean	running
static String	STREAMS_ID

Constructor Summary

Constructors

Constructor and Description
HbasePersistReader()
HbasePersistReader(HbaseConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
protected Queue<StreamsDatum>	constructQueue()
String	getId()
boolean	isRunning()
void	prepare(Object configurationObject)
StreamsResultSet	readAll()
StreamsResultSet	readCurrent()
StreamsResultSet	readNew(BigInteger bigInteger)
StreamsResultSet	readRange(org.joda.time.DateTime dateTime, org.joda.time.DateTime dateTime2)
void	setConfig(HbaseConfiguration config)
void	startStream()
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

lock

protected final ReadWriteLock lock

running

protected final AtomicBoolean running

persistQueue

protected volatile Queue<StreamsDatum> persistQueue

config

protected HbaseConfiguration config

props

protected Properties props

Constructor Detail

HbasePersistReader

public HbasePersistReader()

HbasePersistReader

public HbasePersistReader(HbaseConfiguration config)

Method Detail

setConfig

public void setConfig(HbaseConfiguration config)

getId

public String getId()

Specified by:

getId in interface StreamsOperation

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

readAll

public StreamsResultSet readAll()

Specified by:

readAll in interface StreamsPersistReader

readCurrent

public StreamsResultSet readCurrent()

Specified by:

readCurrent in interface StreamsProvider

constructQueue

protected Queue<StreamsDatum> constructQueue()

readNew

public StreamsResultSet readNew(BigInteger bigInteger)

Specified by:

readNew in interface StreamsPersistReader

Specified by:

readNew in interface StreamsProvider

readRange

public StreamsResultSet readRange(org.joda.time.DateTime dateTime,
                                  org.joda.time.DateTime dateTime2)

Specified by:

readRange in interface StreamsPersistReader

Specified by:

readRange in interface StreamsProvider

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StreamsProvider

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

write

public void write(StreamsDatum streamsDatum)