cascading.tuple.hadoop.util
Class CoGroupingPartitioner

java.lang.Object
  extended by cascading.tuple.util.TupleHasher
      extended by cascading.tuple.hadoop.util.HasherPartitioner
          extended by cascading.tuple.hadoop.util.CoGroupingPartitioner
All Implemented Interfaces:
JobConfigurable, Partitioner<IndexTuple,Tuple>

public class CoGroupingPartitioner
extends HasherPartitioner
implements Partitioner<IndexTuple,Tuple>

Class GroupingPartitioner is an implementation of Partitioner.


Constructor Summary
CoGroupingPartitioner()
           
 
Method Summary
 int getPartition(IndexTuple key, Tuple value, int numReduceTasks)
           
 
Methods inherited from class cascading.tuple.hadoop.util.HasherPartitioner
configure
 
Methods inherited from class cascading.tuple.util.TupleHasher
hashCode, initialize, isNull, merge
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.hadoop.mapred.JobConfigurable
configure
 

Constructor Detail

CoGroupingPartitioner

public CoGroupingPartitioner()
Method Detail

getPartition

public int getPartition(IndexTuple key,
                        Tuple value,
                        int numReduceTasks)
Specified by:
getPartition in interface Partitioner<IndexTuple,Tuple>


Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.