Skip to content

Instantly share code, notes, and snippets.

Show Gist options
  • Save aniquetahir/acb2a781a55cf76a5d2a32d4f0a4d5d6 to your computer and use it in GitHub Desktop.
Save aniquetahir/acb2a781a55cf76a5d2a32d4f0a4d5d6 to your computer and use it in GitHub Desktop.
1.Create a PointRDD objectRDD;
2.Create a RectangleRDD queryWindowRDD;
3.Collect rectangles from queryWindowRDD to one Java List L;
4. For each rectangle R in L
do RangeQuery.SpatialRangeQuery(objectRDD, queryEnvelope, 0, true);
End;
5.Collect all results; //"Collect" is a standard function under SparkContext.
6.Parallelize the results to generate a RDD in this format: JavaPairRDD<Envelope, HashSet<Point>>.;//"Parallelize" is a standard function under SparkContext.
7.Return the result RDD;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment