HDFS之JavaAPI创建目录

HDFS之JavaAPI创建目录

package com.yqq;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.FileSystem;import org.apache.hadoop.fs.Path;import org.junit.Test;import java.io.IOException;import java.net.URI;import java.net.URISyntaxException;/** * @Author yqq * @Date 2021/10/28 00:03 * @Version 1.0 */public class HdfsApiDemo { /** * 创建目录的API演示 */ @Test public void mkdirs_01() throws IOException { //1.创建配置文件对象 Configuration configuration = new Configuration(); //2.指定NameNode configuration.set("fs.defaultFS","hdfs://node1:9820"); //3.创建文件系统对象 FileSystem fileSystem = FileSystem.get(configuration); //4.调用创建目录的API方法 boolean result = fileSystem.mkdirs(new Path("/api/show1")); //关闭文件系统对象 fileSystem.close(); } @Test public void mkdirs_02() throws URISyntaxException, IOException, InterruptedException { //1.创建配置文件对象 Configuration configuration = new Configuration(); //3.创建文件系统对象 FileSystem fileSystem = FileSystem.get(new URI("hdfs://node1:9820"),configuration,"root"); boolean result = fileSystem.mkdirs(new Path("rootAPI/show2")); //关闭文件系统对象 fileSystem.close(); }}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。