import java.io.IOException;import java.net.URI;import java.net.URISyntaxException;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.FileSystem;import org.apache.hadoop.fs.Path;/*** * 创建文件夹 * @author * */public class CreateFolder { public static void main(String[] args) throws IOException, URISyntaxException, InterruptedException { Configuration conf = new Configuration(); //注意修改为自己的IP URI uri=new URI("hdfs://192.168.1.100:9000"); FileSystem fs=FileSystem.get(uri,conf,"hadoop"); /** * uri,conf,"hadoop" 所属于者为hadoop * uri,conf 所属于者为Windows用户 */ //创建目录 fs.mkdirs(new Path("/user/hadoop/ccqq/qq/de/ss")); // fS.mkdirs(new Path("/DataWorld")); }}
评论前必须登录!
立即登录