This project has retired. For details please refer to its Attic page.
JoinUtils.AvroIndexedRecordPartitioner (Apache Crunch 0.8.0 API)

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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Partitioner<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>
      extended by 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>>


Copyright © 2013 The Apache Software Foundation. All Rights Reserved.