-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy path4c.scala
More file actions
12 lines (11 loc) · 716 Bytes
/
Copy path4c.scala
File metadata and controls
12 lines (11 loc) · 716 Bytes
1
2
3
4
5
6
7
8
9
10
11
12
import org.datasyslab.geospark.spatialOperator.JoinQuery;
import org.datasyslab.geospark.spatialRDD.PointRDD;
import org.datasyslab.geospark.spatialRDD.RectangleRDD;
import org.datasyslab.geospark.enums.FileDataSplitter;
import org.datasyslab.geospark.enums.GridType;
import org.datasyslab.geospark.enums.IndexType;
val objectRDD = new PointRDD(sc, "hdfs://master:54310/tmp/arealm.csv", 0, FileDataSplitter.CSV, false);
val rectangleRDD = new RectangleRDD(sc, "hdfs://master:54310/tmp/zcta510.csv", 0, FileDataSplitter.CSV, false);
objectRDD.spatialPartitioning(GridType.RTREE);
rectangleRDD.spatialPartitioning(objectRDD.grids);
val resultSize = JoinQuery.SpatialJoinQuery(objectRDD,rectangleRDD,false).count();