subject:"Creating a smaller, derivative RDD from an RDD"

Re: Creating a smaller, derivative RDD from an RDD

2014-12-18 Thread Sean Owen

Thanks > > bigRdd.flatMap( { i => > val h = md5(i) > if (h.substring(1,1) == 'A') { > Array(h) > } else { > Array[String]() > } > }) > > > > -- > View this message in context: > http://apache

Creating a smaller, derivative RDD from an RDD

2014-12-18 Thread bethesda

in context: http://apache-spark-user-list.1001560.n3.nabble.com/Creating-a-smaller-derivative-RDD-from-an-RDD-tp20769.html Sent from the Apache Spark User List mailing list archive at Nabble.com. - To unsubscribe, e-mail: user