Advertisement
Guest User

Untitled

a guest
Jun 30th, 2015
175
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.29 KB | None | 0 0
  1. case class Feature(name:String, value:Double, time:String, period:String)
  2. RESRDD = RDD.map(tuple=>{var bson=new BasicBSONObject(); bson.put("name",name); bson.put("value",value); (null,bson); })
  3. RESRDD.map(_._2).map(f=>Feature(f.get("name").toString,f.get("value").toString.toDouble).toDF()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement