2017-01-26 5 views

답변

4

구분 기호를 선택하여 csv에 쓸 수 있습니다.

df.write.option("sep","|").option("header","true").csv(filename) 

이것은 100 % 동일하지는 않지만 가까운 것입니다.

또는 당신은 드라이버를 수집하고 그것을 할 youself 예컨대 :

myprint(df.collect()) 

또는

myprint(df.take(100)) 

df.collect 행의 목록을 반환 df.take 수 있습니다.

이 마지막으로 당신이 topandas를 사용하여 드라이버를 수집하고 스파크 2.0에서 팬더 도구

3

을 사용할 수 있습니다, 당신은 내장 CSV 작가 사용할 수 있습니다. 여기에서 delimiter은 기본적으로 ,이며, 사용자는 |

df.write \ 
    .format('csv') \ 
    .options(delimiter='|') \ 
    .save('target/location')