cascading.tuple.hadoop
Class CoGroupingPartitioner

java.lang.Object
  cascading.tuple.hadoop.CoGroupingPartitioner

All Implemented Interfaces:

JobConfigurable, Partitioner<IndexTuple,Tuple>

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

Class GroupingPartitioner is an implementation of Partitioner.

Constructor Summary

CoGroupingPartitioner()

Method Summary

void	configure(JobConf jobConf)
int	getPartition(IndexTuple key, Tuple value, int numReduceTasks)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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>

configure

public void configure(JobConf jobConf)

Specified by:

configure in interface JobConfigurable