hadoop - 未使用 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(“hello\n”);

file.close();