co.cask.cdap.data2.transaction.queue.hbase

Interface HBaseQueueStrategy

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

SaltedHBaseQueueStrategy, ShardedHBaseQueueStrategy

public interface HBaseQueueStrategy
extends Closeable

Interface to represent the strategy being used in queue.

Method Summary

Methods

Modifier and Type	Method and Description
QueueScanner	createScanner(ConsumerConfig consumerConfig, org.apache.hadoop.hbase.client.HTable hTable, org.apache.hadoop.hbase.client.Scan scan, int numRows) Creates a QueueScanner from the given Scan on the HBase table.
byte[]	getActualRowKey(ConsumerConfig consumerConfig, byte[] originalRowKey) Creates the actual row key used for accessing the HBase table from the given queue entry row key.
void	getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs, QueueEntry queueEntry, byte[] rowKeyPrefix, long writePointer, int counter, Collection<byte[]> rowKeys) Get all the row keys that the queue entries need to write to.

Methods inherited from interface java.io.Closeable

close

Method Detail

createScanner

QueueScanner createScanner(ConsumerConfig consumerConfig,
                         org.apache.hadoop.hbase.client.HTable hTable,
                         org.apache.hadoop.hbase.client.Scan scan,
                         int numRows)
                           throws IOException

Creates a QueueScanner from the given Scan on the HBase table.

Parameters:

hTable - HTable for talking to HBase

scan - The scan request

numRows - Maximum number of rows to scan for

Returns:

A QueueScanner that scans over the give table

Throws:

IOException

getActualRowKey

byte[] getActualRowKey(ConsumerConfig consumerConfig,
                     byte[] originalRowKey)

Creates the actual row key used for accessing the HBase table from the given queue entry row key.

getRowKeys

void getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs,
              QueueEntry queueEntry,
              byte[] rowKeyPrefix,
              long writePointer,
              int counter,
              Collection<byte[]> rowKeys)

Get all the row keys that the queue entries need to write to.

Parameters:

consumerGroupConfigs - Consumer groups' configurations for the queue

queueEntry - Entry to enqueue

rowKeyPrefix - Prefix for row keys

writePointer - The writer pointer of the current transaction

counter - The counter of the given entry in this transaction

rowKeys - Collection for storing all the row keys generated by this entry