Loading json data into Pair RDD in Spark using java

2015-09-09 Thread prachicsa
current code: val pairs = setECrecords.flatMap(x => (x.split(","))) pairs.foreach(println) val pairsastuple = pairs.map(x => if(x.split("=").length>1) (x.split("=")(0), x.split("=")(1)) else (x.split("=")(0), x)) -- View this message i

Re: Loading json data into Pair RDD in Spark using java

2015-09-09 Thread Ted Yu
; (x.split(","))) > pairs.foreach(println) > > val pairsastuple = pairs.map(x => if(x.split("=").length>1) > (x.split("=")(0), x.split("=")(1)) else (x.split("=")(0), x)) >