org.apache.pig.backend.hadoop.executionengine.tez.runtime

Class WeightedRangePartitionerTez

java.lang.Object

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

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

org.apache.pig.backend.hadoop.executionengine.tez.runtime.WeightedRangePartitionerTez

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

public class WeightedRangePartitionerTez
extends WeightedRangePartitioner

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.WeightedRangePartitioner

comparator, inited, job, quantiles, weightedParts

Constructor Summary

Constructors

Constructor and Description
WeightedRangePartitionerTez()

Method Summary

Methods

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

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.WeightedRangePartitioner

convertToArray, getConf, getPigNullableWritable, getProbVec, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

WeightedRangePartitionerTez

public WeightedRangePartitionerTez()

Method Detail

getPartition

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

Overrides:

getPartition in class WeightedRangePartitioner

init

public void init()

Overrides:

init in class WeightedRangePartitioner