在hdfs中写入csv

np8igboo  于 2021-06-02  发布在  Hadoop
关注(0)|答案(0)|浏览(460)

我编写了以下函数来使用r在hdfs中写入数据,而am使用rhdfs。

writeToHDFS <- function(fileName){
   hdfs.init()
   modelfile <- hdfs.file(fileName, "w")
   hdfs.write(get(fileName), modelfile)
   hdfs.close(modelfile)
}

如何修改它以csv格式存储这些数据?我已经尝试使用 pipe 但由于它已被弃用,我想通过hdfs.write函数来编写csv文件。
我试过这个:

modelfile <- hdfs.file(paste(fileName, "csv", sep="."), "w")

但我不认为它创建了一个有效的csv,而只是附加了它的扩展。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题