Skip to content

Instantly share code, notes, and snippets.

@dgadiraju

dgadiraju/spark-core-map-get-order-id-and-order-item-subtotal-from-order-items.scala

Created September 5, 2019 14:00
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save dgadiraju/09b48fb1b274268f0cf707dcb8b8a3ac to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save dgadiraju/09b48fb1b274268f0cf707dcb8b8a3ac to your computer and use it in GitHub Desktop.
Download ZIP
Raw
spark-core-map-get-order-id-and-order-item-subtotal-from-order-items.scala
val orderItems = sc.textFile("/public/retail_db/order_items")
val orderItemsMap = orderItems.
map(oi => (oi.split(",")(1).toInt, oi.split(",")(4).toFloat))
orderItemsMap.
take(10).
foreach(println)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment