oracle.spatial.spark.vector.rdd

Class SpatialJavaPairRDD<K,V>

java.lang.Object

<any>

oracle.spatial.spark.vector.rdd.SpatialJavaPairRDD<K,V>

Type Parameters:

K -

V -

public class SpatialJavaPairRDD<K,V>
extends <any>

A pair version of SpatialJavaRDD. This class accepts only SparkRecordInfoProvider instances of type Tuple2<K,V>.

Author:

hsaucedo

Method Summary

Modifier and Type	Method and Description
SpatialTransformationContext<<any>>	createSpatialTransformationContext() Creates an instance of SpatialTransformationContext
SpatialTransformationContext<<any>>	createSpatialTransformationContext(SpatialOperationConfig spatialOperationConf) Creates an instance of SpatialTransformationContext associated to the given SpatialOperationConfig.
SpatialJavaPairRDD<K,V>	filter(<any> f, SpatialOperationConfig spatialOpConf) Returns a new spatial RDD containing only the elements that satisfy both, the filtering lambda function and the spatial operation
<R> <any>	flatMap(<any> f, SpatialOperationConfig spatialOpConf) Returns a new RDD by first spatially filtering the RDD elements using the spatial operation given by spatialOpConf, a function is applied to all the remaining elements.
static <K,V> SpatialJavaPairRDD<K,V>	fromJavaPairRDD(<any> rdd, SparkRecordInfoProvider<<any>> recordInfoProvider, java.lang.Class<K> keyType, java.lang.Class<V> valType) Creates a new spatial RDD from an existing JavaPairRDD
java.lang.Class<K>	getKeyType() Gets the type of the RDD's keys
double[]	getMBR() Gets the minimum bounding rectangle of the RDD
SparkRecordInfoProvider<<any>>	getRecordInfoProvider() Gets the RDD's SparkRecordInfoProvider instance
java.lang.Class<V>	getValueType() Gets the type of the RDD's values
java.util.List<<any>>	nearestNeighbors(<any> f, int k, SpatialOperationConfig spatialOpConf)
java.util.List<<any>>	nearestNeighbors(JGeometry qryWindow, int k, double tol) Returns the k elements which are closest to the given query window

Methods inherited from class java.lang.Object

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

Method Detail

createSpatialTransformationContext

public SpatialTransformationContext<<any>> createSpatialTransformationContext()

Creates an instance of SpatialTransformationContext

Returns:

an instance of SpatialTransformationContext

createSpatialTransformationContext

public SpatialTransformationContext<<any>> createSpatialTransformationContext(SpatialOperationConfig spatialOperationConf)

Creates an instance of SpatialTransformationContext associated to the given SpatialOperationConfig.

Parameters:

spatialOperationConf - a spatial operation used to filter records

Returns:

an instance of SpatialTransformationContext

filter

public SpatialJavaPairRDD<K,V> filter(<any> f,
                                      SpatialOperationConfig spatialOpConf)

Returns a new spatial RDD containing only the elements that satisfy both, the filtering lambda function and the spatial operation

Parameters:

f - a filtering lambda function

spatialOpConf - a spatial operation used to filter records

Returns:

a new SpatialJavaRDD

flatMap

public <R> <any> flatMap(<any> f,
                         SpatialOperationConfig spatialOpConf)

Returns a new RDD by first spatially filtering the RDD elements using the spatial operation given by spatialOpConf, a function is applied to all the remaining elements.

Parameters:

f - a function to apply to each element

spatialOpConf - a spatial operation used to filter records

Returns:

a new RDD

fromJavaPairRDD

public static <K,V> SpatialJavaPairRDD<K,V> fromJavaPairRDD(<any> rdd,
                                                            SparkRecordInfoProvider<<any>> recordInfoProvider,
                                                            java.lang.Class<K> keyType,
                                                            java.lang.Class<V> valType)

Creates a new spatial RDD from an existing JavaPairRDD

Parameters:

rdd - the source RDD

recordInfoProvider - an instance of SparkRecordInfoProvider used to extract spatial information from the RDD's keys and values

keyType - the type of the source RDD keys

valType - the type of the source RDD values

Returns:

a new spatial RDD

getKeyType

public java.lang.Class<K> getKeyType()

Gets the type of the RDD's keys

Returns:

a class type

getMBR

public double[] getMBR()

Gets the minimum bounding rectangle of the RDD

Returns:

a double array containing the following elements: minX, minY, maxX, maxY

getRecordInfoProvider

public SparkRecordInfoProvider<<any>> getRecordInfoProvider()

Gets the RDD's SparkRecordInfoProvider instance

Returns:

a SparkRecordInfoProvider instance

getValueType

public java.lang.Class<V> getValueType()

Gets the type of the RDD's values

Returns:

a class type

nearestNeighbors

public java.util.List<<any>> nearestNeighbors(<any> f,
                                              int k,
                                              SpatialOperationConfig spatialOpConf)

nearestNeighbors

public java.util.List<<any>> nearestNeighbors(JGeometry qryWindow,
                                              int k,
                                              double tol)

Returns the k elements which are closest to the given query window

Parameters:

qryWindow - a geometry from where the nearest neighbors will be calculated

k - the number of neighbors

tol - the tolerance used

Returns:

a list of the k nearest neighbors