我编写了以下函数来使用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,而只是附加了它的扩展。
暂无答案!
目前还没有任何答案,快来回答吧!