使用java api操作HDFS文件系统:
- 1)创建Configuration
- 2)获取FileSystem
- 3)一系列HDFS API操作
package com.haglife.bigdata.hadoop.hdfs;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import java.net.URI;
/**
* 使用java api操作HDFS文件系统:
* 1)创建Configuration
* 2)获取FileSystem
* 3)HDFS API操作
*/
public class HDFSApp {
public static void main(String[] args) throws Exception {
Configuration configuration = new Configuration();
// 操作HDFS文件系统入口
FileSystem fileSystem = FileSystem.get(new URI("hdfs://masternode:8020"), configuration, "uname");
Path path = new Path("/hdfsapi/test");
boolean result = fileSystem.mkdirs(path);
System.out.println(result);
}
}