Hi,
 I have an RDD containing Vehicle Number , timestamp, Position.
 I want to get the "lag" function equivalent to my RDD to be able to create
track segment of each Vehicle.

Any help?

PS: I have tried reduceByKey and then splitting the List of position in
tuples. For me it runs out of memory every time because of the volume of
data.

...Manas

*For some reason I have never got any reply to my emails to the user group.
I am hoping to break that trend this time. :)*

Reply via email to