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

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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Partitioner<Object,Object>
      extended by 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
JoinUtils.AvroIndexedRecordPartitioner()
           
 
Method Summary
 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

JoinUtils.AvroIndexedRecordPartitioner

public JoinUtils.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>


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