K2
- V2
- @InterfaceAudience.Public @InterfaceStability.Stable public class HRegionPartitioner<K2,V2> extends Object implements org.apache.hadoop.mapred.Partitioner<ImmutableBytesWritable,V2>
Modifier and Type | Field and Description |
---|---|
private Connection |
connection |
private RegionLocator |
locator |
private static org.apache.commons.logging.Log |
LOG |
private byte[][] |
startKeys |
Constructor and Description |
---|
HRegionPartitioner() |
Modifier and Type | Method and Description |
---|---|
void |
configure(org.apache.hadoop.mapred.JobConf job) |
int |
getPartition(ImmutableBytesWritable key,
V2 value,
int numPartitions) |
private static final org.apache.commons.logging.Log LOG
private Connection connection
private RegionLocator locator
private byte[][] startKeys
public void configure(org.apache.hadoop.mapred.JobConf job)
configure
in interface org.apache.hadoop.mapred.JobConfigurable
public int getPartition(ImmutableBytesWritable key, V2 value, int numPartitions)
getPartition
in interface org.apache.hadoop.mapred.Partitioner<ImmutableBytesWritable,V2>
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.