我正尝试使用java从apache hadoop中的main方法在hdfs中编写一个字符串变量,如下所示:
for(String s: values)
{
allLine=allLine+s+"\n"; //Here I'm appending all the lines in a single string
}
try
{
FileSystem fs = FileSystem.get(conf);
Path hdfswritepath = new Path("/user/testFile"+(i-1));
FSDataOutputStream outputStream=fs.create(hdfswritepath);
outputStream.writeBytes(allLine);
outputStream.close();
}catch (IOException e)
{
System.out.println(e);
}
在hdfs文件中写入变量allline之后,我发现它只写入了几行,而allline实际上包含了更多的内容。我通过在控制台中打印allline的值来验证它。为什么它不写整个字符串?感谢您的帮助。
暂无答案!
目前还没有任何答案,快来回答吧!