com.asakusafw.runtime.io.util

Class ShuffleKey.Partitioner

java.lang.Object

org.apache.hadoop.mapreduce.Partitioner<ShuffleKey,Object>

com.asakusafw.runtime.io.util.ShuffleKey.Partitioner

Enclosing class:

ShuffleKey<TGroup extends WritableRawComparable,TOrder extends WritableRawComparable>

public static final class ShuffleKey.Partitioner
extends org.apache.hadoop.mapreduce.Partitioner<ShuffleKey,Object>

An implementation of partitioner for ShuffleKey.

Since:

0.2.5

Constructor Summary

Constructors

Constructor and Description
Partitioner()

Method Summary

Modifier and Type	Method and Description
int	getPartition(ShuffleKey key, Object value, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

Partitioner

public Partitioner()

Method Detail

getPartition

public int getPartition(ShuffleKey key,
                        Object value,
                        int numPartitions)

Specified by:

getPartition in class org.apache.hadoop.mapreduce.Partitioner<ShuffleKey,Object>