oracle.spatial.hadoop.vector.join.mapred

Class JoinPartitioner

java.lang.Object

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

public class JoinPartitioner
extends java.lang.Object

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

Author:

hsaucedo

Constructor Summary

Constructors

Constructor and Description
JoinPartitioner()

Method Summary

Modifier and Type	Method and Description
void	configure(JobConf conf)
int	getPartition(JoinGroupWritable key, RecordInfo value, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinPartitioner

public JoinPartitioner()

Method Detail

configure

public void configure(JobConf conf)

getPartition

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