spark-user mailing list archives

Hi all,

I am current working on a project that requires to transform each RDD in a
DStream to a Map. Basically, when we get a list of data in each batch, we
would like to update the global map. I would like to return the map as a
single RDD.

I am currently trying to use the function *transform*. The output will be a
RDD of the updated map after each batch. How can I create an RDD from
another data structure such as Int, Map, ect. Thanks!

Bill