java连接hdfs,创建一个目录,运行说找不到hdfs
查看复制maven仓库的依赖有没有
test
删掉后就恢复正常了
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); } }
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)