This project has retired. For details please refer to its Attic page.

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

JoinUtils.AvroIndexedRecordPartitioner()

Method Summary

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>>