org.apache.crunch.lib.join

Class JoinUtils.TupleWritablePartitioner

java.lang.Object

org.apache.hadoop.mapreduce.Partitioner<TupleWritable,org.apache.hadoop.io.Writable>

org.apache.crunch.lib.join.JoinUtils.TupleWritablePartitioner

Enclosing class:

JoinUtils

public static class JoinUtils.TupleWritablePartitioner
extends org.apache.hadoop.mapreduce.Partitioner<TupleWritable,org.apache.hadoop.io.Writable>

Constructor Summary

Constructors

Constructor and Description
TupleWritablePartitioner()

Method Summary

Modifier and Type	Method and Description
int	getPartition(TupleWritable key, org.apache.hadoop.io.Writable value, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

TupleWritablePartitioner

public TupleWritablePartitioner()

Method Detail

getPartition

public int getPartition(TupleWritable key,
                        org.apache.hadoop.io.Writable value,
                        int numPartitions)

Specified by:

getPartition in class org.apache.hadoop.mapreduce.Partitioner<TupleWritable,org.apache.hadoop.io.Writable>