Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- orders = sc.textFile("/public/retail_db/orders")
- orderItems = sc.textFile("/public/retail_db/order_items")
- ordersFiltered = orders. \
- filter(lambda o: o.split(",")[3] in ["COMPLETE", "CLOSED"])
Add Comment
Please, Sign In to add comment