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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Partitioner<K,V>
      extended by org.apache.hadoop.mapreduce.lib.partition.HashPartitioner<PigNullableWritable,org.apache.hadoop.io.Writable>
          extended by 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
SecondaryKeyPartitioner()
           
 
Method Summary
 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


Copyright © 2007-2012 The Apache Software Foundation