oracle.spatial.spark.vector.index

Class PartitionKeyBasedPartitioner

java.lang.Object

org.apache.spark.Partitioner

oracle.spatial.spark.vector.index.SpatialPartitioner

oracle.spatial.spark.vector.index.PartitionKeyBasedPartitioner

All Implemented Interfaces:

java.io.Serializable

public class PartitionKeyBasedPartitioner
extends SpatialPartitioner

A Partitioner that maps elements from pair RDDs which keys are of type PartitionKey, to partitions of type SpatialPartition which have been previously calculated by a SpatialPartitioning algorithm implementation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PartitionKeyBasedPartitioner(java.util.List<SpatialPartition> partitions) Creates a new instance which will map RDD elements to the given spatial partitions

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
int	getPartition(java.lang.Object obj)
java.util.List<SpatialPartition>	getPartitions() Gets the partitions used to partition an RDD
int	numPartitions()

Methods inherited from class org.apache.spark.Partitioner

defaultPartitioner

Methods inherited from class java.lang.Object

clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartitionKeyBasedPartitioner

public PartitionKeyBasedPartitioner(java.util.List<SpatialPartition> partitions)

Creates a new instance which will map RDD elements to the given spatial partitions

Parameters:

partitions -

Method Detail

numPartitions

public int numPartitions()

Specified by:

numPartitions in class org.apache.spark.Partitioner

getPartition

public int getPartition(java.lang.Object obj)

Specified by:

getPartition in class org.apache.spark.Partitioner

getPartitions

public java.util.List<SpatialPartition> getPartitions()

Description copied from class: SpatialPartitioner

Gets the partitions used to partition an RDD

Specified by:

getPartitions in class SpatialPartitioner

Returns:

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object