博客

需要注意的：

1.mkdirs可以在深度上新建多个文件夹。

2.在配置中已经定义了uri，所以mkdirs中可以不写hdfs：//nodename/

package hadoop.hdfs;

import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

import org.apache.commons.io.IOUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.junit.jupiter.api.Test;

public class HDFSUtil {

	@Test
	public void mkdir() throws IOException, InterruptedException, URISyntaxException{
		//新建文件夹
		Configuration conf=new Configuration();//加载配置项
		FileSystem fs = FileSystem.get(new URI("hdfs://Ubuntu01:9000/"),conf,"czq");//加载文件系统实例
		fs.mkdirs(new Path("/aa/bb/cc/dd"));//新建文件夹
	}
}