我用java语言编写了以下用户定义函数:
我定义了filewriter,但执行后会显示一条错误消息。
课程: outputFile = new FileWriter("hdfs://NaeNode:9000/input/SG.csv",true); fw = new BufferedWriter(outputFile);
从udf:trial.u guess中捕获错误[hdfs:/naemnode:9000/input/sg.csv (无此类文件或目录)]
既然我在执行时使用了[pig-x mapreduce fie.pig],我该如何解决这个问题
1条答案
按热度按时间tyky79it1#
要存储在hdfs中,必须使用fsdataoutputstream。
filesystem.create返回fsdataoutputstream。
请参见下面的代码。