HDFS的客户端操作(1)
(一)创建文件夹
在根目录下去创建一个名为maven的文件夹。
要用到的api是fs.mkdirs。
核心代码如下:
public void testMkdirs() throws IOException, URISyntaxException, InterruptedException {// 1 获取文件系统Configuration conf = new Configuration();conf.set("fs.defaultFS", "hdfs://hadoop100:8020"); // hadoop100是namenode所在的节点conf.set("hadoop.job.ugi", "root"); // 2 创建新文件fs.mkdirs(new Path("/maven"));// 3 关闭资源fs.close();
}
点击运行之后,我们遇到一个错误:
此时,需要去设置登录的用户名。
System.setProperty("HADOOP_USER_NAME", "root")
然后再去尝试。去到hdfs的UI界面上去检查是否运行成功。