使用java从本地主机在远程hdfs上创建目录

odopli94  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(408)

从localhost在远程hdfs上创建一个目录
写了代码但不明白该写什么和在哪里写 core-site.xml 以及 hdfs-site.xml .

  1. public class HadoopCall {
  2. public void demomkdir(String dir) throws IOException
  3. {
  4. Configuration obj = new Configuration();
  5. obj.set("fs.defaultFS", "http://datlpdsnn01.pds.in.****.com:50070/");
  6. FileSystem fs = FileSystem.get(obj);
  7. Path pth = new Path(dir);
  8. fs.mkdirs(pth);
  9. System.out.println("created");
  10. fs.close();
  11. }
  12. public static void main(String[] args) throws IOException {
  13. HadoopCall oj = new HadoopCall();
  14. oj.demomkdir("user/*******/javacodemkdir");
  15. }
  16. }
prdp8dxp

prdp8dxp1#

参考:hadoop配置类
如上链接所示:
core-default.xml:hadoop的只读默认值。
core-site.xml:给定hadoop安装的特定于站点的配置。
这两个文件都是特定于安装和默认配置的文件。可以使用addresource(path)方法添加上述任何xml的路径。如果没有给定路径,则从类路径变量推断xml文件路径。

相关问题