文件夹不是使用hadoop mapreduce代码创建的

9gm1akwq  于 2021-06-03  发布在  Hadoop
关注(0)|答案(2)|浏览(258)

我正在尝试创建一个在“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”文件,对吗?

4si2a6ki

4si2a6ki1#

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

bin/hadoop fs -mkdir <paths>
cqoc49vn

cqoc49vn2#

试试这个

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();

相关问题