class PointRDD extends SpatialRDD[Point]
The Class PointRDD.
- Alphabetic
- By Inheritance
- PointRDD
- SpatialRDD
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
PointRDD(sparkContext: JavaSparkContext, InputLocation: String, Offset: Integer, splitter: FileDataSplitter, carryInputData: Boolean, partitions: Integer)
Instantiates a new point RDD.
Instantiates a new point RDD.
- sparkContext
the spark context
- InputLocation
the input location
- Offset
the offset
- splitter
the splitter
- carryInputData
the carry input data
- partitions
the partitions
-
new
PointRDD(sparkContext: JavaSparkContext, InputLocation: String, userSuppliedMapper: FlatMapFunction[_, _])
Instantiates a new point RDD.
Instantiates a new point RDD.
- sparkContext
the spark context
- InputLocation
the input location
- userSuppliedMapper
the user supplied mapper
-
new
PointRDD(sparkContext: JavaSparkContext, InputLocation: String, partitions: Integer, userSuppliedMapper: FlatMapFunction[_, _])
Instantiates a new point RDD.
Instantiates a new point RDD.
- sparkContext
the spark context
- InputLocation
the input location
- partitions
the partitions
- userSuppliedMapper
the user supplied mapper
-
new
PointRDD(sparkContext: JavaSparkContext, InputLocation: String, splitter: FileDataSplitter, carryInputData: Boolean)
Instantiates a new point RDD.
Instantiates a new point RDD.
- sparkContext
the spark context
- InputLocation
the input location
- splitter
the splitter
- carryInputData
the carry input data
-
new
PointRDD(sparkContext: JavaSparkContext, InputLocation: String, splitter: FileDataSplitter, carryInputData: Boolean, partitions: Integer)
Instantiates a new point RDD.
Instantiates a new point RDD.
- sparkContext
the spark context
- InputLocation
the input location
- splitter
the splitter
- carryInputData
the carry input data
- partitions
the partitions
-
new
PointRDD(sparkContext: JavaSparkContext, InputLocation: String, Offset: Integer, splitter: FileDataSplitter, carryInputData: Boolean)
Instantiates a new point RDD.
Instantiates a new point RDD.
- sparkContext
the spark context
- InputLocation
the input location
- Offset
the offset
- splitter
the splitter
- carryInputData
the carry input data
-
new
PointRDD(rawSpatialRDD: JavaRDD[Point])
Instantiates a new point RDD.
Instantiates a new point RDD.
- rawSpatialRDD
the raw spatial RDD
- new PointRDD()
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
- Definition Classes
- SpatialRDD
-
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
- Definition Classes
- SpatialRDD
-
def
analyze(datasetBoundary: Envelope, approximateTotalCount: Integer): Boolean
- Definition Classes
- SpatialRDD
-
def
analyze(): Boolean
Analyze.
-
def
analyze(newLevel: StorageLevel): Boolean
Analyze.
-
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
- Definition Classes
- SpatialRDD
- 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
- Definition Classes
- SpatialRDD
- 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
- Definition Classes
- SpatialRDD
- Exceptions thrown
Exception
the exception
-
def
countWithoutDuplicates(): Long
Count without duplicates.
-
def
countWithoutDuplicatesSPRDD(): Long
Count without duplicates SPRDD.
-
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
- Definition Classes
- SpatialRDD
-
def
getCRStransformation(): Boolean
Gets the CR stransformation.
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getPartitioner(): SpatialPartitioner
- Definition Classes
- SpatialRDD
-
def
getRawSpatialRDD(): JavaRDD[Point]
Gets the raw spatial RDD.
-
def
getSampleNumber(): Int
- Definition Classes
- SpatialRDD
-
def
getSourceEpsgCode(): String
Gets the source epsg code.
-
def
getTargetEpgsgCode(): String
Gets 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.
-
def
saveAsWKB(outputLocation: String): Unit
Save as WKB.
-
def
saveAsWKT(outputLocation: String): Unit
Save as WKT
Save as WKT
- Definition Classes
- SpatialRDD
-
def
setNeighborSampleNumber(neighborSampleNumber: Int): Unit
Sets the neighbor sample number.
Sets the neighbor sample number.
- neighborSampleNumber
the new neighbor sample number
- Definition Classes
- SpatialRDD
-
def
setRawSpatialRDD(rawSpatialRDD: JavaRDD[Point]): Unit
Sets the raw spatial RDD.
-
def
setSampleNumber(sampleNumber: Int): Unit
Sets the sample number.
-
def
spatialPartitioning(partitioner: SpatialPartitioner): Unit
- Definition Classes
- SpatialRDD
-
def
spatialPartitioning(gridType: GridType, numPartitions: Int): Unit
- Definition Classes
- SpatialRDD
-
def
spatialPartitioning(gridType: GridType): Boolean
- Definition Classes
- SpatialRDD
-
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
- Definition Classes
- SpatialRDD
- 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.
- Definition Classes
- 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
- Definition Classes
- SpatialRDD
- Exceptions thrown
-
def
spatialPartitioningWithoutDuplicates(gridType: GridType): Boolean
- Definition Classes
- SpatialRDD
-
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
- Definition Classes
- SpatialRDD
- Annotations
- @Deprecated
- Deprecated
-
def
boundary(): Envelope
Boundary.
-
def
spatialPartitioning(partitionTree: StandardQuadTree[_]): Boolean
- Definition Classes
- SpatialRDD
- Deprecated
Use spatialPartitioning(SpatialPartitioner partitioner)
-
def
spatialPartitioning(otherGrids: List[Envelope]): Boolean
- Definition Classes
- SpatialRDD
- Deprecated
Use spatialPartitioning(SpatialPartitioner partitioner)