org.apache.hadoop.hbase.mapreduce

Class IntegrationTestBulkLoad.NaturalKeyPartitioner

java.lang.Object

org.apache.hadoop.mapreduce.Partitioner<IntegrationTestBulkLoad.LinkKey,IntegrationTestBulkLoad.LinkChain>

org.apache.hadoop.hbase.mapreduce.IntegrationTestBulkLoad.NaturalKeyPartitioner

Enclosing class:

IntegrationTestBulkLoad

public static class IntegrationTestBulkLoad.NaturalKeyPartitioner
extends org.apache.hadoop.mapreduce.Partitioner<IntegrationTestBulkLoad.LinkKey,IntegrationTestBulkLoad.LinkChain>

Class to figure out what partition to send a link in the chain to. This is based upon the linkKey's ChainId.

Constructor Summary

Constructors

Constructor and Description
NaturalKeyPartitioner()

Method Summary

Modifier and Type	Method and Description
int	getPartition(IntegrationTestBulkLoad.LinkKey linkKey, IntegrationTestBulkLoad.LinkChain linkChain, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

NaturalKeyPartitioner

public NaturalKeyPartitioner()

Method Detail

getPartition

public int getPartition(IntegrationTestBulkLoad.LinkKey linkKey,
                        IntegrationTestBulkLoad.LinkChain linkChain,
                        int numPartitions)

Specified by:

getPartition in class org.apache.hadoop.mapreduce.Partitioner<IntegrationTestBulkLoad.LinkKey,IntegrationTestBulkLoad.LinkChain>