public class HDFSClientDemo {
    public static void main(String[] args) throws IOException, InterruptedException {
        //远程操作hadoop集群
        //获取文件系统
        Configuration conf = new Configuration();
        //设置集群配置信息，键值对 (因为在本机上没有配置host，所以"hdfs://hadoop161:9000"无法识别，需改成要操作的机子的ip地址)
        conf.set("fs.defaultFS","hdfs://192.168.12.161:9000");
        //拦截本机user用户然后改成集群上的hadoop用户
        System.setProperty("HADOOP_USER_NAME","hadoop");
        //获取HDFS客户端对象
        FileSystem fs = FileSystem.get(conf);
        //在hdfs上创建目录
        fs.mkdirs(new Path("/0300/abc"));
        //关闭资源（释放资源）
        fs.close();
        //验证程序是否结束
        System.out.println("over");

    }
}