com.cloudera.crunch.lib
Class JoinUtils.AvroIndexedRecordPartitioner

java.lang.Object
  org.apache.hadoop.mapreduce.Partitioner<org.apache.avro.mapred.AvroKey,org.apache.avro.mapred.AvroValue>
      com.cloudera.crunch.lib.JoinUtils.AvroIndexedRecordPartitioner

Enclosing class:

JoinUtils

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

Constructor Summary

JoinUtils.AvroIndexedRecordPartitioner()

Method Summary

int	getPartition(org.apache.avro.mapred.AvroKey key, org.apache.avro.mapred.AvroValue value, int numPartitions)

Methods inherited from class java.lang.Object

clone, equals, finalize, 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 key,
                        org.apache.avro.mapred.AvroValue value,
                        int numPartitions)

Specified by:

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