- All Implemented Interfaces:
- org.apache.hadoop.conf.Configurable
public class SkewedPartitioner
extends org.apache.hadoop.mapreduce.Partitioner<PigNullableWritable,org.apache.hadoop.io.Writable>
implements org.apache.hadoop.conf.Configurable
This class is used by skewed join. For the partitioned table, the skewedpartitioner reads the key
distribution data from the sampler file and returns the reducer index in a round robin fashion.
For ex: if the key distribution file contains (k1, 5, 3) as an entry, reducers from 5 to 3 are returned
in a round robin manner.