Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- (0,1), (0,1), (0,2), (1,2), (1,10), (1,20), (3,18), (3,18), (3,18)
- 1,2,18
- 1,10,18
- 2,20,18
- >>> rdd = sc.parallelize([(0,1), (0,1), (0,2), (1,2), (1,10), (1,20), (3,18), (3,18), (3,18)])
- >>> sqlContext.createDataFrame(rdd, ["id", "score"])
- Out[2]: DataFrame[id: bigint, score: bigint]
Advertisement
Add Comment
Please, Sign In to add comment