oracle.spatial.spark.vector.rdd

Class SpatialTransformationContext<T>

java.lang.Object

oracle.spatial.spark.vector.rdd.SpatialTransformationContext<T>

Type Parameters:

T -

All Implemented Interfaces:

java.io.Serializable

public class SpatialTransformationContext<T>
extends java.lang.Object
implements java.io.Serializable

A class used internally by spatial RDDs to distribute the transformation information and the SparkInfoProvider across nodes.

Author:

hsaucedo

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SpatialTransformationContext(SparkRecordInfoProvider<T> recordInfoProvider) Creates a new instance which uses the given SparkRecordInfoProvider
SpatialTransformationContext(SparkRecordInfoProvider<T> recordInfoProvider, SpatialOperationConfig spatialOpConf) Creates a new instance which uses the given SparkRecordInfoProvider and can filter using the specified SpatialOperationConfig

Method Summary

Modifier and Type	Method and Description
boolean	filter(T record) Returns true if the given record passes the spatial filter specified by the current SpatialOperationConfig if any.
boolean	filter(T record, SpatialOperationConfig spatialOpConf) Returns if the given record passes the spatial filter specified by the given SpatialOperationConfig.
JGeometry	getGeometry(T record) Gets the geometry of the given record
SparkRecordInfo	getRecordInfo(T record) Gets a SparkRecordInfo containing information from the give record.
boolean	isPreSpatialFiltering()
static boolean	isPreSpatialFiltering(SpatialOperationConfig spatialOpConf)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpatialTransformationContext

public SpatialTransformationContext(SparkRecordInfoProvider<T> recordInfoProvider)

Creates a new instance which uses the given SparkRecordInfoProvider

Parameters:

recordInfoProvider -

SpatialTransformationContext

public SpatialTransformationContext(SparkRecordInfoProvider<T> recordInfoProvider,
                                    SpatialOperationConfig spatialOpConf)

Creates a new instance which uses the given SparkRecordInfoProvider and can filter using the specified SpatialOperationConfig

Parameters:

recordInfoProvider -

spatialOpConf -

Method Detail

filter

public boolean filter(T record)
               throws java.lang.Exception

Returns true if the given record passes the spatial filter specified by the current SpatialOperationConfig if any. A NullPointerException will be thrown if there is not a SpatialOperationConfig in the current context.

Parameters:

record -

Returns:

true if the record passes the spatial filter of the current context

Throws:

java.lang.Exception

filter

public boolean filter(T record,
                      SpatialOperationConfig spatialOpConf)
               throws java.lang.Exception

Returns if the given record passes the spatial filter specified by the given SpatialOperationConfig.

Parameters:

record -

spatialOpConf -

Returns:

true if the record passes the spatial filter

Throws:

java.lang.Exception

getGeometry

public JGeometry getGeometry(T record)

Gets the geometry of the given record

Parameters:

record - an RDD record which can be processed by the current SparkRecordInfoProvider

Returns:

a JGeometry instance or null if either, the record does not have spatial information or could not be processed by the current SparkRecordInfoProvider

getRecordInfo

public SparkRecordInfo getRecordInfo(T record)

Gets a SparkRecordInfo containing information from the give record.

Be aware that SparkRecordInfo instances can be reused so different calls with different input records may return the same instance with different data. If the record info will be part of a new RDD, a new record info instance should be created from the existing one. See SparkRecordInfo.SparkRecordInfo(SparkRecordInfo) and SparkRecordInfo.setRecordInfo(SparkRecordInfo).

Parameters:

record - a record which can be processed by the current SparkRecordInfoProvider

Returns:

an instance of SparkRecordInfo or null if the input record could not be processed by the current SparkRecordInfoProvider

isPreSpatialFiltering

public boolean isPreSpatialFiltering()

isPreSpatialFiltering

public static boolean isPreSpatialFiltering(SpatialOperationConfig spatialOpConf)