assignment 13 - veeraravi/Spark-notes GitHub Wiki

var pa_df = sqlContext.sql("select * from retail_db.provider_attribute").filter(pa_df["attribute_id"] === "PRVATYPICAL").filter(pa_df("the_value") === "YES"); val resultDf = pa_df.withColumn('atypical_attribute_FL',lit('true'))