单机版使用的是FileSystem类的静态函数:
FileSystem hdfs = FileSystem.get(conf)
伪分布式下需要使用Path来获得
Path path = new Path("hdfs://mlj:9000/dir"); FileSystem hdfs = path.getFileSystem(jobConf);
时间: 2024-10-25 09:23:32
单机版使用的是FileSystem类的静态函数:
FileSystem hdfs = FileSystem.get(conf)
伪分布式下需要使用Path来获得
Path path = new Path("hdfs://mlj:9000/dir"); FileSystem hdfs = path.getFileSystem(jobConf);