org.apache.crunch.lib.join

Class JoinUtils.AvroIndexedRecordPartitioner

java.lang.Object

org.apache.hadoop.mapreduce.Partitioner<Object,Object>

org.apache.crunch.lib.join.JoinUtils.AvroIndexedRecordPartitioner

Enclosing class:

JoinUtils

public static class JoinUtils.AvroIndexedRecordPartitioner
extends org.apache.hadoop.mapreduce.Partitioner<Object,Object>

Constructor Summary

Constructors

Constructor and Description
AvroIndexedRecordPartitioner()

Method Summary

Modifier and Type	Method and Description
int	getPartition(Object key, Object value, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroIndexedRecordPartitioner

public AvroIndexedRecordPartitioner()

Method Detail

getPartition

public int getPartition(Object key,
                        Object value,
                        int numPartitions)

Specified by:

getPartition in class org.apache.hadoop.mapreduce.Partitioner<Object,Object>