org.apache.hadoop.hbase.regionserver

Class DelimitedKeyPrefixRegionSplitRestriction

java.lang.Object

org.apache.hadoop.hbase.regionserver.RegionSplitRestriction

org.apache.hadoop.hbase.regionserver.DelimitedKeyPrefixRegionSplitRestriction

@InterfaceAudience.Private
public class DelimitedKeyPrefixRegionSplitRestriction
extends RegionSplitRestriction

A RegionSplitRestriction implementation that groups rows by a prefix of the row-key with a delimiter. Only the first delimiter for the row key will define the prefix of the row key that is used for grouping.

This ensures that a region is not split "inside" a prefix of a row key. I.e. rows can be co-located in a region by their prefix. As an example, if you have row keys delimited with _, like userid_eventtype_eventid, and use prefix delimiter _, this split policy ensures that all rows starting with the same userid, belongs to the same region.

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	delimiter
static String	DELIMITER_KEY
private static org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.regionserver.RegionSplitRestriction

RESTRICTION_TYPE_DELIMITED_KEY_PREFIX, RESTRICTION_TYPE_KEY, RESTRICTION_TYPE_KEY_PREFIX, RESTRICTION_TYPE_NONE

Constructor Summary

Constructors

Constructor and Description
DelimitedKeyPrefixRegionSplitRestriction()

Method Summary

Modifier and Type	Method and Description
byte[]	getRestrictedSplitPoint(byte[] splitPoint) Returns a restricted split point.
void	initialize(TableDescriptor tableDescriptor, org.apache.hadoop.conf.Configuration conf) Initialize the RegionSplitRestriction instance

Methods inherited from class org.apache.hadoop.hbase.regionserver.RegionSplitRestriction

create

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

DELIMITER_KEY

public static final String DELIMITER_KEY

See Also:

Constant Field Values

delimiter

private byte[] delimiter

Constructor Detail

DelimitedKeyPrefixRegionSplitRestriction

public DelimitedKeyPrefixRegionSplitRestriction()

Method Detail

initialize

public void initialize(TableDescriptor tableDescriptor,
                       org.apache.hadoop.conf.Configuration conf)
                throws IOException

Description copied from class: RegionSplitRestriction

Initialize the RegionSplitRestriction instance

Specified by:

initialize in class RegionSplitRestriction

Parameters:

tableDescriptor - the table descriptor

conf - the configuration

Throws:

IOException - if an error occurs

getRestrictedSplitPoint

public byte[] getRestrictedSplitPoint(byte[] splitPoint)

Description copied from class: RegionSplitRestriction

Returns a restricted split point.

Specified by:

getRestrictedSplitPoint in class RegionSplitRestriction

Parameters:

splitPoint - the split point determined by RegionSplitPolicy or specified by a user manually

Returns:

the restricted split point