oracle.spatial.hadoop.vector.join.mapred

Class JoinPartitioner

java.lang.Object

oracle.spatial.hadoop.vector.join.mapred.JoinPartitioner

All Implemented Interfaces:

org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Partitioner<JoinGroupWritable,RecordInfo>

public class JoinPartitioner
extends java.lang.Object
implements org.apache.hadoop.mapred.Partitioner<JoinGroupWritable,RecordInfo>

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

Modifier and Type	Method and Description
void	configure(org.apache.hadoop.mapred.JobConf conf)
int	getPartition(JoinGroupWritable key, RecordInfo value, int numPartitions)

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

configure

public void configure(org.apache.hadoop.mapred.JobConf conf)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

getPartition

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

Specified by:

getPartition in interface org.apache.hadoop.mapred.Partitioner<JoinGroupWritable,RecordInfo>