val sqlContext = new SQLContext(sc) sqlContext.setConf("spark.sql.shuffle.partitions", "2") import sqlContext.implicits._