def row2csv(row):
    buffer = cStringIO.StringIO()
writer = csv.writer(buffer)
writer.writerow([str(s).encode('utf-8') for s in row])
buffer.seek(0)
return buffer.read().strip()
df.rdd.map(row2csv).coalesce(1).saveAsTextFile('file.csv')
как экспортировать фрейм данных таблицы в pyspark в csv?