org.apache.crunch.lib.join

Class JoinUtils.AvroIndexedRecordPartitioner<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.Partitioner<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>

org.apache.crunch.lib.join.JoinUtils.AvroIndexedRecordPartitioner<K,V>

Enclosing class:

JoinUtils

public static class JoinUtils.AvroIndexedRecordPartitioner<K,V>
extends org.apache.hadoop.mapreduce.Partitioner<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>

Constructor Summary

Constructors

Constructor and Description
JoinUtils.AvroIndexedRecordPartitioner()

Method Summary

Methods

Modifier and Type	Method and Description
int	getPartition(org.apache.avro.mapred.AvroKey<K> key, org.apache.avro.mapred.AvroValue<V> value, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinUtils.AvroIndexedRecordPartitioner

public JoinUtils.AvroIndexedRecordPartitioner()

Method Detail

getPartition

public int getPartition(org.apache.avro.mapred.AvroKey<K> key,
               org.apache.avro.mapred.AvroValue<V> value,
               int numPartitions)

Specified by:

getPartition in class org.apache.hadoop.mapreduce.Partitioner<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>