oracle.spatial.spark.vector.rdd

Class StatefulSpatialTransformationContext<T>

java.lang.Object

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

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

Type Parameters:

T -

All Implemented Interfaces:

java.io.Serializable

public class StatefulSpatialTransformationContext<T>
extends SpatialTransformationContext<T>

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
StatefulSpatialTransformationContext(SparkRecordInfoProvider<T> recordInfoProvider) Creates a new instance which uses the given SparkRecordInfoProvider
StatefulSpatialTransformationContext(SparkRecordInfoProvider<T> recordInfoProvider, SpatialOperationConfig spatialOpConf) Creates a new instance which uses the given SparkRecordInfoProvider and can filter using the specified SpatialOperationConfig
StatefulSpatialTransformationContext(SpatialTransformationContext<T> ctx)

Method Summary

Modifier and Type	Method and Description
JGeometry	getGeometry(T record) Gets the geometry of the given record
SparkRecordInfo	getRecordInfo(T record) Gets a SparkRecordInfo containing information from the give record.

Methods inherited from class oracle.spatial.spark.vector.rdd.SpatialTransformationContext

filter, filter, isPreSpatialFiltering, isPreSpatialFiltering

Methods inherited from class java.lang.Object

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

Constructor Detail

StatefulSpatialTransformationContext

public StatefulSpatialTransformationContext(SparkRecordInfoProvider<T> recordInfoProvider)

Creates a new instance which uses the given SparkRecordInfoProvider

Parameters:

recordInfoProvider -

StatefulSpatialTransformationContext

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

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

Parameters:

recordInfoProvider -

spatialOpConf -

StatefulSpatialTransformationContext

public StatefulSpatialTransformationContext(SpatialTransformationContext<T> ctx)

Method Detail

getGeometry

public JGeometry getGeometry(T record)

Gets the geometry of the given record

Overrides:

getGeometry in class SpatialTransformationContext<T>

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).

Overrides:

getRecordInfo in class SpatialTransformationContext<T>

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