使用HDFS API读取HDFS中的文件并显示

在Hadoop分布式文件系统（HDFS）中，HDFS API提供了一组Java接口和工具，用于与HDFS进行交互，包括读取文件。以下是使用Hadoop 2.x版本的HDFS API读取文件的基本步骤：

1. 导入必要的库：首先，你需要导入`org.apache.hadoop.conf.Configuration`和`org.apache.hadoop.fs.FileSystem`等HDFS相关的包。

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

2. 初始化配置：创建一个`Configuration`对象，并设置所需的HDFS连接信息，如默认名称节点地址。

Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://your namenode hostname:port");

将`your namenode hostname:port`替换为你实际的Hadoop集群的名称节点地址。

3. 创建文件系统实例：通过`FileSystem`的静态方法`get()`，使用配置创建一个`FileSystem`实例。

FileSystem fs = FileSystem.get(conf);

4. 定义文件路径：构建你要读取的文件的`Path`对象。

Path filePath = new Path("/path/to/your/file.txt");

5. 打开文件并读取：调用`open()`方法打开文件，然后使用`DataInputStream`读取数据。

try (DataInputStream in = fs.open(filePath)) {
    byte[] buffer = new byte[1024];
    int bytesRead;
    while ((bytesRead = in.read(buffer)) != -1) {
        String line = new String(buffer, 0, bytesRead);
        System.out.println(line);
    }
} catch (IOException e) {
    e.printStackTrace();
}

6. 关闭文件：确保在完成操作后关闭`DataInputStream`和`FileSystem`。

in.close();
fs.close();