Guest User

Untitled

a guest
May 2nd, 2015
228
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.29 KB | None | 0 0
  1. (0,1), (0,1), (0,2), (1,2), (1,10), (1,20), (3,18), (3,18), (3,18)
  2.  
  3. 1,2,18
  4. 1,10,18
  5. 2,20,18
  6.  
  7. >>> rdd = sc.parallelize([(0,1), (0,1), (0,2), (1,2), (1,10), (1,20), (3,18), (3,18), (3,18)])
  8. >>> sqlContext.createDataFrame(rdd, ["id", "score"])
  9. Out[2]: DataFrame[id: bigint, score: bigint]
Advertisement
Add Comment
Please, Sign In to add comment