class SpatialRDD[T <: Geometry] extends Serializable
The Class SpatialRDD.
- Alphabetic
- By Inheritance
- SpatialRDD
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new SpatialRDD()
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
CRSTransform(sourceEpsgCRSCode: String, targetEpsgCRSCode: String): Boolean
CRS transform.
CRS transform.
- sourceEpsgCRSCode
the source epsg CRS code
- targetEpsgCRSCode
the target epsg CRS code
- returns
true, if successful
-
def
CRSTransform(sourceEpsgCRSCode: String, targetEpsgCRSCode: String, lenient: Boolean): Boolean
CRS transform.
CRS transform.
- sourceEpsgCRSCode
the source epsg CRS code
- targetEpsgCRSCode
the target epsg CRS code
- lenient
consider the difference of the geodetic datum between the two coordinate systems, if
true
, never throw an exception "Bursa-Wolf Parameters Required", but not recommended for careful analysis work- returns
true, if successful
- def analyze(datasetBoundary: Envelope, approximateTotalCount: Integer): Boolean
-
def
analyze(): Boolean
Analyze.
Analyze.
- returns
true, if successful
-
def
analyze(newLevel: StorageLevel): Boolean
Analyze.
Analyze.
- newLevel
the new level
- returns
true, if successful
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
buildIndex(indexType: IndexType, buildIndexOnSpatialPartitionedRDD: Boolean): Unit
Builds the index.
Builds the index.
- indexType
the index type
- buildIndexOnSpatialPartitionedRDD
the build index on spatial partitioned RDD
- Exceptions thrown
Exception
the exception
-
def
calc_partitioner(gridType: GridType, numPartitions: Int): Unit
Spatial partitioning.
Spatial partitioning.
- gridType
the grid type
- numPartitions
the target number of partitions
- Exceptions thrown
Exception
the exception
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
coalesceAndBuildRawIndex(indexType: IndexType): STRtree
Builds the index on coalesced raw spatial RDD.
Builds the index on coalesced raw spatial RDD.
- indexType
the index type
- Exceptions thrown
Exception
the exception
-
def
countWithoutDuplicates(): Long
Count without duplicates.
Count without duplicates.
- returns
the long
-
def
countWithoutDuplicatesSPRDD(): Long
Count without duplicates SPRDD.
Count without duplicates SPRDD.
- returns
the long
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def flipCoordinates(): Unit
-
def
getCRStransformation(): Boolean
Gets the CR stransformation.
Gets the CR stransformation.
- returns
the CR stransformation
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getPartitioner(): SpatialPartitioner
-
def
getRawSpatialRDD(): JavaRDD[T]
Gets the raw spatial RDD.
Gets the raw spatial RDD.
- returns
the raw spatial RDD
- def getSampleNumber(): Int
-
def
getSourceEpsgCode(): String
Gets the source epsg code.
Gets the source epsg code.
- returns
the source epsg code
-
def
getTargetEpgsgCode(): String
Gets the target epgsg code.
Gets the target epgsg code.
- returns
the target epgsg code
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
saveAsGeoJSON(outputLocation: String): Unit
Save as geo JSON.
Save as geo JSON.
- outputLocation
the output location
-
def
saveAsWKB(outputLocation: String): Unit
Save as WKB.
Save as WKB.
- outputLocation
the output location
-
def
saveAsWKT(outputLocation: String): Unit
Save as WKT
-
def
setNeighborSampleNumber(neighborSampleNumber: Int): Unit
Sets the neighbor sample number.
Sets the neighbor sample number.
- neighborSampleNumber
the new neighbor sample number
-
def
setRawSpatialRDD(rawSpatialRDD: JavaRDD[T]): Unit
Sets the raw spatial RDD.
Sets the raw spatial RDD.
- rawSpatialRDD
the new raw spatial RDD
-
def
setSampleNumber(sampleNumber: Int): Unit
Sets the sample number.
Sets the sample number.
- sampleNumber
the new sample number
- def spatialPartitioning(partitioner: SpatialPartitioner): Unit
- def spatialPartitioning(gridType: GridType, numPartitions: Int): Unit
- def spatialPartitioning(gridType: GridType): Boolean
-
def
spatialPartitioningWithoutDuplicates(otherGrids: List[Envelope]): Boolean
Calculate non-duplicate inducing partitioning based on a list of existing envelopes
Calculate non-duplicate inducing partitioning based on a list of existing envelopes
This is shorthand for spatialPartitioningWithoutDuplicates(new IndexedGridPartitioner()). Using spatialPartitioningWithoutDuplicates(gridType, numPartitions) is typically more appropriate because it is able to adapt to the content of the partition and is able to produce more consistently balanced partitions.
Note that non-duplicating partitioners are intended for use by distributed partitioned writers and not able to be used for spatial joins.
- otherGrids
A list of existing envelopes
- returns
true on success
- Exceptions thrown
-
def
spatialPartitioningWithoutDuplicates(partitioner: SpatialPartitioner): Unit
Calculate non-duplicate inducing partitioning from an existing SpatialPartitioner
Calculate non-duplicate inducing partitioning from an existing SpatialPartitioner
Note that non-duplicating partitioners are intended for use by distributed partitioned writers and not able to be used for spatial joins.
- partitioner
An existing partitioner obtained from the partitioning of another SpatialRDD.
- Exceptions thrown
-
def
spatialPartitioningWithoutDuplicates(gridType: GridType, numPartitions: Int): Unit
Calculate non-duplicate inducing partitioning
Calculate non-duplicate inducing partitioning
Note that non-duplicating partitioners are intended for use by distributed partitioned writers and not able to be used for spatial joins.
- gridType
The target GridType
- numPartitions
The target number of partitions
- Exceptions thrown
- def spatialPartitioningWithoutDuplicates(gridType: GridType): Boolean
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
Deprecated Value Members
-
def
MinimumBoundingRectangle(): RectangleRDD
Minimum bounding rectangle.
Minimum bounding rectangle.
- returns
the rectangle RDD
- Annotations
- @Deprecated
- Deprecated
-
def
boundary(): Envelope
Boundary.
Boundary.
- returns
the envelope
- Deprecated
Call analyze() instead
-
def
spatialPartitioning(partitionTree: StandardQuadTree[_]): Boolean
- Deprecated
Use spatialPartitioning(SpatialPartitioner partitioner)
-
def
spatialPartitioning(otherGrids: List[Envelope]): Boolean
- Deprecated
Use spatialPartitioning(SpatialPartitioner partitioner)