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
-
Method Summary
Modifier and TypeMethodDescriptionint
getPartition
(IntegrationTestBulkLoad.LinkKey linkKey, IntegrationTestBulkLoad.LinkChain linkChain, int numPartitions)
-
Constructor Details
-
NaturalKeyPartitioner
public NaturalKeyPartitioner()
-
-
Method Details
-
getPartition
public int getPartition(IntegrationTestBulkLoad.LinkKey linkKey, IntegrationTestBulkLoad.LinkChain linkChain, int numPartitions) - Specified by:
getPartition
in classorg.apache.hadoop.mapreduce.Partitioner<IntegrationTestBulkLoad.LinkKey,
IntegrationTestBulkLoad.LinkChain>
-