Package org.apache.hadoop.hbase.mapred

Class HRegionPartitioner<K2,V2>

java.lang.Object

org.apache.hadoop.hbase.mapred.HRegionPartitioner<K2,V2>

Type Parameters:

K2 -

V2 -

All Implemented Interfaces:

org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Partitioner<ImmutableBytesWritable,V2>

@Public
public class HRegionPartitioner<K2,V2>
extends Object
implements org.apache.hadoop.mapred.Partitioner<ImmutableBytesWritable,V2>

This is used to partition the output keys into groups of keys. Keys are grouped according to the regions that currently exist so that each reducer fills a single region so load is distributed.

Field Summary

Fields

Modifier and Type	Field	Description
private Connection	connection
private RegionLocator	locator
private static final org.slf4j.Logger	LOG
private byte[][]	startKeys

Constructor Summary

Constructors

Constructor	Description
HRegionPartitioner()

Method Summary

Modifier and Type	Method	Description
void	configure(org.apache.hadoop.mapred.JobConf job)
int	getPartition(ImmutableBytesWritable key, V2 value, int numPartitions)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

connection

private Connection connection

locator

private RegionLocator locator

startKeys

private byte[][] startKeys

Constructor Details

HRegionPartitioner

public HRegionPartitioner()

Method Details

configure

public void configure(org.apache.hadoop.mapred.JobConf job)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

getPartition

public int getPartition(ImmutableBytesWritable key,
 V2 value,
 int numPartitions)

Specified by:

getPartition in interface org.apache.hadoop.mapred.Partitioner<K2,V2>