a guest Sep 20th, 2019 86 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
- val orders = sc.textFile("/public/retail_db/orders")
- val ordersMap = orders.
- map(o => (o.split(",")(0).toInt, o))
- val orderItems = sc.textFile("/public/retail_db/order_items")
- val orderItemsMap = orderItems.
- map(oi => (oi.split(",")(1).toInt, oi))
- val ordersJoin = ordersMap.
- val ordersLeftOuterJoin = ordersMap.
RAW Paste Data