org.apache.hadoop.hbase.mob.mapreduce

Class MobFilePathHashPartitioner

java.lang.Object

org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.Text,KeyValue>

org.apache.hadoop.hbase.mob.mapreduce.MobFilePathHashPartitioner

@InterfaceAudience.Private
public class MobFilePathHashPartitioner
extends org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.Text,KeyValue>

The partitioner for the sweep job. The key is a mob file name. We bucket by date.

Constructor Summary

Constructors

Constructor and Description
MobFilePathHashPartitioner()

Method Summary

Methods

Modifier and Type	Method and Description
int	getPartition(org.apache.hadoop.io.Text fileName, KeyValue kv, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

MobFilePathHashPartitioner

public MobFilePathHashPartitioner()

Method Detail

getPartition

public int getPartition(org.apache.hadoop.io.Text fileName,
               KeyValue kv,
               int numPartitions)

Specified by:

getPartition in class org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.Text,KeyValue>