org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners

Class SecondaryKeyPartitioner

java.lang.Object

org.apache.hadoop.mapreduce.Partitioner<K,V>

org.apache.hadoop.mapreduce.lib.partition.HashPartitioner<PigNullableWritable,org.apache.hadoop.io.Writable>

org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.SecondaryKeyPartitioner

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

public class SecondaryKeyPartitioner
extends org.apache.hadoop.mapreduce.lib.partition.HashPartitioner<PigNullableWritable,org.apache.hadoop.io.Writable>
implements org.apache.hadoop.conf.Configurable

Constructor Summary

Constructors

Constructor and Description
SecondaryKeyPartitioner()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.conf.Configuration	getConf()
int	getPartition(PigNullableWritable key, org.apache.hadoop.io.Writable value, int numPartitions)
void	setConf(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Constructor Detail

SecondaryKeyPartitioner

public SecondaryKeyPartitioner()

Method Detail

getPartition

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

Overrides:

getPartition in class org.apache.hadoop.mapreduce.lib.partition.HashPartitioner<PigNullableWritable,org.apache.hadoop.io.Writable>

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable