co.cask.cdap.data2.transaction.stream.hbase

Class HBaseStreamConsumerStateStore

java.lang.Object

co.cask.cdap.data2.transaction.stream.StreamConsumerStateStore

co.cask.cdap.data2.transaction.stream.hbase.HBaseStreamConsumerStateStore

All Implemented Interfaces:

ConsumerStateStore<StreamConsumerState,Iterable<StreamFileOffset>>, Closeable, AutoCloseable

public final class HBaseStreamConsumerStateStore
extends StreamConsumerStateStore

Field Summary

Fields inherited from class co.cask.cdap.data2.transaction.stream.StreamConsumerStateStore

streamConfig, streamId

Constructor Summary

Constructors

Constructor and Description
HBaseStreamConsumerStateStore(StreamConfig streamConfig, org.apache.hadoop.hbase.client.HTable hTable) Constructor to create an instance for a given stream.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected void	delete(byte[] row, Set<byte[]> columns) Deletes the set of columns from the given row.
protected byte[]	fetch(byte[] row, byte[] column) Fetches the cell value for the given row and column.
protected void	fetchAll(byte[] row, byte[] columnPrefix, Map<byte[],byte[]> result) Fetches all values for the given row.
protected void	fetchAll(byte[] row, Map<byte[],byte[]> result) Fetches all values for the given row.
protected void	store(byte[] row, byte[] column, byte[] value) Stores the given value to cell identified by the given row and column.
protected void	store(byte[] row, Map<byte[],byte[]> values) Stores all the values to the given row.

Methods inherited from class co.cask.cdap.data2.transaction.stream.StreamConsumerStateStore

get, getAll, getByGroup, remove, save, save

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseStreamConsumerStateStore

public HBaseStreamConsumerStateStore(StreamConfig streamConfig,
                             org.apache.hadoop.hbase.client.HTable hTable)

Constructor to create an instance for a given stream.

Parameters:

streamConfig - configuration information of the stream.

hTable - for communicating with HBase for backing store.

Method Detail

close

public void close()
           throws IOException

Throws:

IOException

fetch

protected byte[] fetch(byte[] row,
           byte[] column)
                throws IOException

Description copied from class: StreamConsumerStateStore

Fetches the cell value for the given row and column. If no such value exists, null should be returned.

Specified by:

fetch in class StreamConsumerStateStore

Throws:

IOException

fetchAll

protected void fetchAll(byte[] row,
            Map<byte[],byte[]> result)
                 throws IOException

Description copied from class: StreamConsumerStateStore

Fetches all values for the given row.

Specified by:

fetchAll in class StreamConsumerStateStore

Parameters:

row - the row to fetch from.

result - a map from column to value.

Throws:

IOException

fetchAll

protected void fetchAll(byte[] row,
            byte[] columnPrefix,
            Map<byte[],byte[]> result)
                 throws IOException

Description copied from class: StreamConsumerStateStore

Fetches all values for the given row. Children can optionally use the columnPrefix to do more efficient retrieval.

Specified by:

fetchAll in class StreamConsumerStateStore

Parameters:

row - the row to fetch from.

columnPrefix - the column prefix.

result - a map from column to value. It's valid to contains columns that don't start with columnPrefix.

Throws:

IOException

store

protected void store(byte[] row,
         byte[] column,
         byte[] value)
              throws IOException

Description copied from class: StreamConsumerStateStore

Stores the given value to cell identified by the given row and column.

Specified by:

store in class StreamConsumerStateStore

Throws:

IOException

store

protected void store(byte[] row,
         Map<byte[],byte[]> values)
              throws IOException

Description copied from class: StreamConsumerStateStore

Stores all the values to the given row.

Specified by:

store in class StreamConsumerStateStore

Parameters:

row - the row to store to.

values - Map from column name to value.

Throws:

IOException

delete

protected void delete(byte[] row,
          Set<byte[]> columns)
               throws IOException

Description copied from class: StreamConsumerStateStore

Deletes the set of columns from the given row.

Specified by:

delete in class StreamConsumerStateStore

Parameters:

row - the row to act on.

columns - columns to get deleted.

Throws:

IOException