dgadiraju
11/4/2017 - 3:13 PM

create-orders-and-items-data-frames.scala

import com.databricks.spark.avro._;
   var ordersDF = sqlContext.read.avro("/user/cloudera/problem1/orders");
   var orderItemDF = sqlContext.read.avro("/user/cloudera/problem1/order-items");