alue pair.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Change-RDDs-using-map-tp14436p14481.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
-
To unsubscrib
You don't. That's what filter or the partial function version of collect
are for:
val transformedRDD = yourRDD.collect { case (k, v) if k == 1 => v }
On Wed, Sep 17, 2014 at 3:24 AM, Deep Pradhan
wrote:
> Hi,
> I want to make the following changes in the RDD (create new RDD from the
> existing
Hi,
I want to make the following changes in the RDD (create new RDD from the
existing to reflect some transformation):
In an RDD of key-value pair, I want to get the keys for which the values
are 1.
How to do this using map()?
Thank You
