a guest Feb 17th, 2018 65 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
- l = range(1, 10000)
- lRDD = sc.parallelize(l)
- productsRaw = open("/data/retail_db/products/part-00000").read().splitlines()
- productsRDD = sc.parallelize(productsRaw)
- for i in productsRDD.take(10): print(i)
RAW Paste Data