Uses of Class
co.cask.cdap.hbase.wd.AbstractRowKeyDistributor

Packages that use AbstractRowKeyDistributor

Package	Description
co.cask.cdap.data2.transaction.stream.hbase	This package contains class for stream consumer implementation that uses HBase as state store.
co.cask.cdap.data2.util.hbase
co.cask.cdap.hbase.wd	Classes in this package implement row salting approach to distribute writes with monotonically increasing keys to multiple regions.

Uses of AbstractRowKeyDistributor in co.cask.cdap.data2.transaction.stream.hbase

Constructors in co.cask.cdap.data2.transaction.stream.hbase with parameters of type AbstractRowKeyDistributor

Constructor and Description
HBaseStreamFileConsumer(CConfiguration cConf, StreamConfig streamConfig, ConsumerConfig consumerConfig, HBaseTableUtil tableUtil, org.apache.hadoop.hbase.client.HTable hTable, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, ReadFilter extraFilter, AbstractRowKeyDistributor keyDistributor) Constructor.

Uses of AbstractRowKeyDistributor in co.cask.cdap.data2.util.hbase

Methods in co.cask.cdap.data2.util.hbase with parameters of type AbstractRowKeyDistributor

Modifier and Type	Method and Description
static byte[][]	HBaseTableUtil.getSplitKeys(int splits, int buckets, AbstractRowKeyDistributor keyDistributor)

Uses of AbstractRowKeyDistributor in co.cask.cdap.hbase.wd

Subclasses of AbstractRowKeyDistributor in co.cask.cdap.hbase.wd

Modifier and Type	Class and Description
class	RowKeyDistributorByHashPrefix Provides handy methods to distribute
class	RowKeyDistributorByOneBytePrefix Provides handy methods to distribute

Methods in co.cask.cdap.hbase.wd with parameters of type AbstractRowKeyDistributor

Modifier and Type	Method and Description
static DistributedScanner	DistributedScanner.create(org.apache.hadoop.hbase.client.HTableInterface hTable, org.apache.hadoop.hbase.client.Scan originalScan, AbstractRowKeyDistributor keyDistributor, ExecutorService scansExecutor)