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

Question

从本地主机在远程 HDFS 上创建目录

写了代码，但不明白core-site.xml和hdfs-site.xml的内容和位置。

public class HadoopCall {

    public void demomkdir(String dir) throws IOException
    {
        Configuration obj = new Configuration();

        obj.set("fs.defaultFS", "http://datlpdsnn01.pds.in.****.com:50070/");
        FileSystem fs = FileSystem.get(obj);

        Path pth = new Path(dir);
        fs.mkdirs(pth);
        System.out.println("created");
        fs.close(); 
    }

    public static void main(String[] args) throws IOException {
        HadoopCall oj = new HadoopCall();
        oj.demomkdir("user/*******/javacodemkdir");
    }

}

Answer 1

引用:Hadoop Configuration class

如上面的链接所示:

core-default.xml: Read-only defaults for hadoop.

core-site.xml: Site-specific configuration for a given hadoop installation.

两者都是文件，具有特定于安装的配置和默认配置。您可以使用addResource(Path path)方法添加上述任何xml的路径。如果未给出路径，则从类路径变量推断 xml 文件路径。