VALUE
- @InterfaceAudience.Public 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.
since 0.90.0
|
(package private) static String |
END_BASE64 |
private byte[] |
endkey |
private int |
lastReduces |
private static org.slf4j.Logger |
LOG |
private byte[][] |
splits |
static String |
START
Deprecated.
since 0.90.0
|
(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.slf4j.Logger 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 SimpleTotalOrderPartitioner()
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.Configurable
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.