import scala.collection.mutable.HashMap import org.apache.spark._ import org.apache.spark.sql.SQLContext import org.apache.spark.sql.functions._ import org.apache.spark.sql.hive.HiveContext val options = new HashMap[String, String] options.put("spark.hadoop.mapred.output.compress", "true") options.put("spark.hadoop.mapred.output.compression.codec", "true") options.put("spark.hadoop.mapred.output.c