Merge pull request #54 from invadergir/partitioning-fix-1.5

Fix for Spark < 1.6. Thanks @invadergir !
apache · Feb 8, 2017 · 73becac · 73becac
2 parents dc94551 + c0327c2
commit 73becac
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/datasyslab/geospark/spatialRDD/SpatialRDD.java b/src/main/java/org/datasyslab/geospark/spatialRDD/SpatialRDD.java
@@ -83,7 +83,7 @@ public abstract class SpatialRDD implements Serializable{
 	 */
 	public boolean spatialPartitioning(GridType gridType) throws Exception
 	{
-        int numPartitions = this.rawSpatialRDD.getNumPartitions();
+        int numPartitions = this.rawSpatialRDD.rdd().partitions().length;
 		if(this.boundaryEnvelope==null)
         {
         	throw new Exception("[AbstractSpatialRDD][spatialPartitioning] SpatialRDD boundary is null. Please call boundary() first.");