文件夹未使用 Hadoop Mapreduce 代码创建

Question

我正在尝试在"in"文件夹中创建一个文件。 但是当我尝试在集群中运行它时，我注意到这个"in"文件夹不在 HDFS 中。

为什么会这样？

有什么不对吗？

我的驱动程序代码是

    Path in = new Path("in");
    Path input = new Path("in/inputfile");
    BufferedWriter createinput = new BufferedWriter(new OutputStreamWriter(fs.create(input)));

根据此代码，应该在群集的工作目录中创建一个"in"文件夹和一个文件"inputfile"，对吗？

Answer 1

您还可以使用 unix 命令创建文件夹。

bin/hadoop fs -mkdir <paths>

Answer 2

试试这个

Path p = new Path(“hdfs://node1:50070/foo/bar”);
FileSystem fs = p.getFileSystem(conf);
DataOutputStream file = fs.create(p);
file.writeUTF(“hellon”);
file.close();