T
-public class QuadTreePartitioning<T> extends java.lang.Object implements java.io.Serializable, SpatialPartitioning<T>
SpatialPartitioning
that uses a QuadTree to partition an existing spatial RDDConstructor and Description |
---|
QuadTreePartitioning(JavaSparkContext sc, SpatialJavaRDD<T> rdd, QuadTreeConfiguration quadTreConf)
Creates a new instance and partitions the given RDD using the given configuration
|
Modifier and Type | Method and Description |
---|---|
SpatialPartitioner |
createPartitioner(java.util.List<SpatialPartition> partitions)
Creates a
SpatialPartitioner based on the given spatial partitions |
SpatialJavaPairRDD<PartitionKey,T> |
getPartitionedRDD()
Gets the current spatially partitioned spatial RDD
|
SpatialPartitioner |
getPartitioner()
Gets the
SpatialPartitioner instance used to generated the partitioned RDD |
public QuadTreePartitioning(JavaSparkContext sc, SpatialJavaRDD<T> rdd, QuadTreeConfiguration quadTreConf)
sc
- an existing SparkContextrdd
- a spatial RDD to be spatially partitionedquadTreConf
- a configuration containing the options for partitioningpublic SpatialPartitioner createPartitioner(java.util.List<SpatialPartition> partitions)
SpatialPartitioning
SpatialPartitioner
based on the given spatial partitionscreatePartitioner
in interface SpatialPartitioning<T>
public SpatialJavaPairRDD<PartitionKey,T> getPartitionedRDD()
SpatialPartitioning
getPartitionedRDD
in interface SpatialPartitioning<T>
public SpatialPartitioner getPartitioner()
SpatialPartitioning
SpatialPartitioner
instance used to generated the partitioned RDDgetPartitioner
in interface SpatialPartitioning<T>
Copyright © 2017 Oracle and/or its affiliates. All Rights Reserved.