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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Partitioner<PigNullableWritable,org.apache.hadoop.io.Writable>
      extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.WeightedRangePartitioner
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable

public class WeightedRangePartitioner
extends org.apache.hadoop.mapreduce.Partitioner<PigNullableWritable,org.apache.hadoop.io.Writable>
implements org.apache.hadoop.conf.Configurable


Field Summary
static Map<PigNullableWritable,DiscreteProbabilitySampleGenerator> weightedParts
           
 
Constructor Summary
WeightedRangePartitioner()
           
 
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 configuration)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

weightedParts

public static final Map<PigNullableWritable,DiscreteProbabilitySampleGenerator> weightedParts
Constructor Detail

WeightedRangePartitioner

public WeightedRangePartitioner()
Method Detail

getPartition

public int getPartition(PigNullableWritable key,
                        org.apache.hadoop.io.Writable value,
                        int numPartitions)
Specified by:
getPartition in class org.apache.hadoop.mapreduce.Partitioner<PigNullableWritable,org.apache.hadoop.io.Writable>

setConf

public void setConf(org.apache.hadoop.conf.Configuration configuration)
Specified by:
setConf in interface org.apache.hadoop.conf.Configurable

getConf

public org.apache.hadoop.conf.Configuration getConf()
Specified by:
getConf in interface org.apache.hadoop.conf.Configurable


Copyright © 2007-2012 The Apache Software Foundation