co.cask.cdap.hbase.wd

Class AbstractRowKeyDistributor

java.lang.Object

co.cask.cdap.hbase.wd.AbstractRowKeyDistributor

All Implemented Interfaces:

Parametrizable

Direct Known Subclasses:

RowKeyDistributorByHashPrefix, RowKeyDistributorByOneBytePrefix

public abstract class AbstractRowKeyDistributor
extends Object
implements Parametrizable

Defines the way row keys are distributed.

Constructor Summary

Constructors

Constructor and Description
AbstractRowKeyDistributor()

Method Summary

Methods

Modifier and Type	Method and Description
void	addInfo(Configuration conf)
abstract byte[][]	getAllDistributedKeys(byte[] originalKey)
org.apache.hadoop.hbase.util.Pair<byte[],byte[]>[]	getDistributedIntervals(byte[] originalStartKey, byte[] originalStopKey) Gets all distributed intervals based on the original start & stop keys.
abstract byte[]	getDistributedKey(byte[] originalKey)
org.apache.hadoop.hbase.client.Scan[]	getDistributedScans(org.apache.hadoop.hbase.client.Scan original)
abstract byte[]	getOriginalKey(byte[] adjustedKey)

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.cdap.hbase.wd.Parametrizable

getParamsToStore, init

Constructor Detail

AbstractRowKeyDistributor

public AbstractRowKeyDistributor()

Method Detail

getDistributedKey

public abstract byte[] getDistributedKey(byte[] originalKey)

getOriginalKey

public abstract byte[] getOriginalKey(byte[] adjustedKey)

getAllDistributedKeys

public abstract byte[][] getAllDistributedKeys(byte[] originalKey)

getDistributedIntervals

public org.apache.hadoop.hbase.util.Pair<byte[],byte[]>[] getDistributedIntervals(byte[] originalStartKey,
                                                                         byte[] originalStopKey)

Gets all distributed intervals based on the original start & stop keys. Used when scanning all buckets based on start/stop row keys. Should return keys so that all buckets in which records between originalStartKey and originalStopKey were distributed are "covered".

Parameters:

originalStartKey - start key

originalStopKey - stop key

Returns:

array[Pair(startKey, stopKey)]

getDistributedScans

public final org.apache.hadoop.hbase.client.Scan[] getDistributedScans(org.apache.hadoop.hbase.client.Scan original)
                                                                throws IOException

Throws:

IOException

addInfo

public void addInfo(Configuration conf)