Using pyspark I have grid coordinates (x,y) and individual points that lie within each grid square so I have:
rdd1 = ((x,y), [point1, point2, point3])
I also have an rdd of points that were moved into that grid so:
rdd2 = ((x, y), [point4, point5, point6])
I want to merge these so that I have:
merged_rdd = ((x,y), [point1, point2, point3], [point4, point5, point6])