from pyspark import SparkContext df = sqlContext.createDataFrame(rdd, ['count', 'word']) # Write CSV (I have HDFS storage) df.coalesce(1).write.format('com.databricks.spark.csv').options(header='true').save('file:///home/username/csv_out')
