Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- case class Feature(name:String, value:Double, time:String, period:String)
- RESRDD = RDD.map(tuple=>{var bson=new BasicBSONObject(); bson.put("name",name); bson.put("value",value); (null,bson); })
- 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