dgadiraju · September 5, 2019 12:22
diff --git a/spark-core-countByKey-01-order-count-for-each-day.scala b/spark-core-countByKey-01-order-count-for-each-day.scala
 val orders = sc.textFile("/public/retail_db/orders")

 val ordersMap = orders.
  map(o => (o.split(",")(1), 1))

 ordersMap.
  countByKey.
  take(10).
  foreach(println)
diff --git a/spark-core-countByKey-02-order-count-for-each-status.scala b/spark-core-countByKey-02-order-count-for-each-status.scala
 val orders = sc.textFile("/public/retail_db/orders")

 val ordersMap = orders.
  map(o => (o.split(",")(3), 1))

 ordersMap.
  countByKey.
  take(10).
  foreach(println)
	val orders = sc.textFile("/public/retail_db/orders")

	val ordersMap = orders.
	map(o => (o.split(",")(1), 1))

	ordersMap.
	countByKey.
	take(10).
	foreach(println)
	val orders = sc.textFile("/public/retail_db/orders")

	val ordersMap = orders.
	map(o => (o.split(",")(3), 1))

	ordersMap.
	countByKey.
	take(10).
	foreach(println)