VALUE - @InterfaceAudience.Public @InterfaceStability.Stable public class SimpleTotalOrderPartitioner<VALUE> extends org.apache.hadoop.mapreduce.Partitioner<ImmutableBytesWritable,VALUE> implements org.apache.hadoop.conf.Configurable
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.| Modifier and Type | Field and Description |
|---|---|
private org.apache.hadoop.conf.Configuration |
c |
static String |
END
Deprecated.
|
(package private) static String |
END_BASE64 |
private byte[] |
endkey |
private int |
lastReduces |
private static org.apache.commons.logging.Log |
LOG |
private byte[][] |
splits |
static String |
START
Deprecated.
|
(package private) static String |
START_BASE64 |
private byte[] |
startkey |
| Constructor and Description |
|---|
SimpleTotalOrderPartitioner() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.conf.Configuration |
getConf() |
(package private) static byte[] |
getEndKey(org.apache.hadoop.conf.Configuration conf) |
private static byte[] |
getKeyFromConf(org.apache.hadoop.conf.Configuration conf,
String base64Key,
String deprecatedKey) |
int |
getPartition(ImmutableBytesWritable key,
VALUE value,
int reduces) |
(package private) static byte[] |
getStartKey(org.apache.hadoop.conf.Configuration conf) |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
static void |
setEndKey(org.apache.hadoop.conf.Configuration conf,
byte[] endKey) |
static void |
setStartKey(org.apache.hadoop.conf.Configuration conf,
byte[] startKey) |
private static final org.apache.commons.logging.Log LOG
@Deprecated public static final String START
@Deprecated public static final String END
static final String START_BASE64
static final String END_BASE64
private org.apache.hadoop.conf.Configuration c
private byte[] startkey
private byte[] endkey
private byte[][] splits
private int lastReduces
public static void setStartKey(org.apache.hadoop.conf.Configuration conf,
byte[] startKey)
public static void setEndKey(org.apache.hadoop.conf.Configuration conf,
byte[] endKey)
static byte[] getStartKey(org.apache.hadoop.conf.Configuration conf)
static byte[] getEndKey(org.apache.hadoop.conf.Configuration conf)
private static byte[] getKeyFromConf(org.apache.hadoop.conf.Configuration conf,
String base64Key,
String deprecatedKey)
public int getPartition(ImmutableBytesWritable key, VALUE value, int reduces)
getPartition in class org.apache.hadoop.mapreduce.Partitioner<ImmutableBytesWritable,VALUE>public org.apache.hadoop.conf.Configuration getConf()
getConf in interface org.apache.hadoop.conf.Configurablepublic void setConf(org.apache.hadoop.conf.Configuration conf)
setConf in interface org.apache.hadoop.conf.ConfigurableCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.