org.apache.hadoop.hbase.mapreduce

Class SimpleTotalOrderPartitioner<VALUE>

java.lang.Object

<any>

org.apache.hadoop.hbase.mapreduce.SimpleTotalOrderPartitioner<VALUE>

Type Parameters:

VALUE -

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class SimpleTotalOrderPartitioner<VALUE>
extends <any>

A partitioner that takes start and end keys and uses bigdecimal to figure which reduce a key belongs to. Pass the start and end keys in the Configuration using hbase.simpletotalorder.start and hbase.simpletotalorder.end. The end key needs to be exclusive; i.e. one larger than the biggest key in your key space. You may be surprised at how this class partitions the space; it may not align with preconceptions; e.g. a start key of zero and an end key of 100 divided in ten will not make regions whose range is 0-10, 10-20, and so on. Make your own partitioner if you need the region spacing to come out a particular way.

See Also:

START, END

Field Summary

Fields

Modifier and Type	Field and Description
static String	END Deprecated.
static String	START Deprecated.

Constructor Summary

Constructors

Constructor and Description
SimpleTotalOrderPartitioner()

Method Summary

Modifier and Type	Method and Description
Configuration	getConf()
int	getPartition(ImmutableBytesWritable key, VALUE value, int reduces)
void	setConf(Configuration conf)
static void	setEndKey(Configuration conf, byte[] endKey)
static void	setStartKey(Configuration conf, byte[] startKey)

Methods inherited from class java.lang.Object

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

Field Detail

START

@Deprecated
public static final String START

Deprecated.

See Also:

Constant Field Values

END

@Deprecated
public static final String END

Deprecated.

See Also:

Constant Field Values

Constructor Detail

SimpleTotalOrderPartitioner

public SimpleTotalOrderPartitioner()

Method Detail

setStartKey

public static void setStartKey(Configuration conf,
                               byte[] startKey)

setEndKey

public static void setEndKey(Configuration conf,
                             byte[] endKey)

getPartition

public int getPartition(ImmutableBytesWritable key,
                        VALUE value,
                        int reduces)

getConf

public Configuration getConf()

setConf

public void setConf(Configuration conf)