0
votes

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])