hdfs java api流程

HDFS（Hadoop Distributed File System）的Java API流程如下：

1. 创建一个Configuration对象，它包含了Hadoop的配置信息。

2. 创建一个FileSystem对象，它代表了HDFS中的一个文件系统。可以通过FileSystem类的静态工厂方法get()来获取一个FileSystem实例。

3. 使用FileSystem对象创建一个Path对象，它代表了HDFS中的一个路径，可以是文件或目录。

4. 使用FileSystem对象调用相应的方法，例如create()创建一个文件，mkdirs()创建一个目录等等。

5. 通过InputStream或OutputStream对象读取或写入数据。可以使用FSDataInputStream和FSDataOutputStream类来操作HDFS中的文件。

6. 关闭FileSystem和流。

下面是Java代码示例：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;

public class HDFSJavaAPIExample {
    public static void main(String[] args) {
        try {
            // 创建Configuration对象
            Configuration conf = new Configuration();
            
            // 创建FileSystem对象
            FileSystem fs = FileSystem.get(conf);
            
            // 创建Path对象
            Path path = new Path("/user/hadoop/example.txt");
            
            // 创建文件并写入数据
            FSDataOutputStream out = fs.create(path);
            out.write("Hello HDFS!".getBytes());
            out.close();
            
            // 读取文件数据
            FSDataInputStream in = fs.open(path);
            byte[] buffer = new byte[1024];
            int bytesRead = in.read(buffer);
            String content = new String(buffer, 0, bytesRead);
            System.out.println("File content: " + content);
            in.close();
            
            // 关闭FileSystem对象
            fs.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}