oracle.spatial.hadoop.vector.join.mapreduce

Class JoinPartitioner

java.lang.Object

<any>

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

public class JoinPartitioner
extends <any>

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
Configuration	getConf()
int	getPartition(JoinGroupWritable key, RecordInfo value, int numPartitions)
void	setConf(Configuration conf)

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinPartitioner

public JoinPartitioner()

Method Detail

getConf

public Configuration getConf()

getPartition

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

setConf

public void setConf(Configuration conf)