oracle.spatial.hadoop.vector.join.mapreduce

Class JoinPartitioner

java.lang.Object

org.apache.hadoop.mapreduce.Partitioner<JoinGroupWritable,RecordInfo>

oracle.spatial.hadoop.vector.join.mapreduce.JoinPartitioner

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

public class JoinPartitioner
extends org.apache.hadoop.mapreduce.Partitioner<JoinGroupWritable,RecordInfo>
implements org.apache.hadoop.conf.Configurable

Implementation of Partitioner. Loads a previously generated PartitioningResult and distributes the spatial partitions among the reducers so each reducer processes approximately the same number of records.
The PartitioningResult file is searched in the distributed cache using the symbolic link ConfigParams.PARTITIONING_RESULT

Constructor Summary

Constructors

Constructor and Description
JoinPartitioner()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.conf.Configuration	getConf()
int	getPartition(JoinGroupWritable key, RecordInfo 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

JoinPartitioner

public JoinPartitioner()

Method Detail

setConf

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

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

getPartition

public int getPartition(JoinGroupWritable key,
                        RecordInfo value,
                        int numPartitions)

Specified by:

getPartition in class org.apache.hadoop.mapreduce.Partitioner<JoinGroupWritable,RecordInfo>