java连接hdfs,创建一个目录,运行说找不到hdfs
查看复制maven仓库的依赖有没有
<scope>test</scope>
删掉后就恢复正常了
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.*;
import java.net.URI;
public class HadoopAPI {
public static void main(String[] args)throws Exception{
//使用9000端口号,50070是客户端的端口号
URI uri = new URI("hdfs://master:9000");
//获取hadoop的hdfs配置文件,只要new出来就算获取成功,利用conf对象就可以修改配置
Configuration conf = new Configuration();
//举个例子,使用conf对象设置副本数量为1
conf.set("dfs.replication","1");
//获取文件系统对象fs,利用fs来对hdfs中的文件进行操作
FileSystem fs = FileSystem.get(uri,conf);
fs = FileSystem.get(uri,conf);
}
}
?
?
?
|