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

Class HBaseQueueClientFactory

java.lang.Object

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

All Implemented Interfaces:

QueueClientFactory

public class HBaseQueueClientFactory
extends Object
implements QueueClientFactory

Factory for creating HBase queue producer and consumer instances.

Constructor Summary

Constructors

Constructor and Description
HBaseQueueClientFactory(CConfiguration cConf, Configuration hConf, HBaseTableUtil hBaseTableUtil, QueueAdmin queueAdmin, co.cask.tephra.TransactionExecutorFactory txExecutorFactory)

Method Summary

Methods

Modifier and Type	Method and Description
QueueConsumer	createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)
org.apache.hadoop.hbase.client.HTable	createHTable(TableId tableId)
QueueProducer	createProducer(QueueName queueName)
QueueProducer	createProducer(QueueName queueName, QueueMetrics queueMetrics)
int	getDistributorBuckets(org.apache.hadoop.hbase.HTableDescriptor htd)
HBaseQueueAdmin	getQueueAdmin()

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseQueueClientFactory

@Inject
public HBaseQueueClientFactory(CConfiguration cConf,
                              Configuration hConf,
                              HBaseTableUtil hBaseTableUtil,
                              QueueAdmin queueAdmin,
                              co.cask.tephra.TransactionExecutorFactory txExecutorFactory)

Method Detail

createProducer

public QueueProducer createProducer(QueueName queueName)
                             throws IOException

Specified by:

createProducer in interface QueueClientFactory

Throws:

IOException

createProducer

public QueueProducer createProducer(QueueName queueName,
                           QueueMetrics queueMetrics)
                             throws IOException

Specified by:

createProducer in interface QueueClientFactory

Throws:

IOException

createConsumer

public QueueConsumer createConsumer(QueueName queueName,
                           ConsumerConfig consumerConfig,
                           int numGroups)
                             throws IOException

Specified by:

createConsumer in interface QueueClientFactory

Throws:

IOException

getQueueAdmin

public HBaseQueueAdmin getQueueAdmin()

createHTable

public org.apache.hadoop.hbase.client.HTable createHTable(TableId tableId)
                                                   throws IOException

Throws:

IOException

getDistributorBuckets

public int getDistributorBuckets(org.apache.hadoop.hbase.HTableDescriptor htd)