hdfsRead 怎么判断文件是否读完给出例子

在Hadoop中，可以使用FSDataInputStream类的available()方法来判断文件是否读取完毕。available()方法返回输入流中剩余的可读字节数。如果返回值为0，则表示文件已经读取完毕。

以下是一个使用FSDataInputStream来判断文件是否读取完毕的示例代码：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.*;

public class HdfsReadExample {

    public static void main(String[] args) throws Exception {
        // 创建一个Hadoop配置对象
        Configuration conf = new Configuration();
        // 设置HDFS的URI
        conf.set("fs.defaultFS", "hdfs://localhost:9000");
        
        // 获取HDFS文件系统实例
        FileSystem fs = FileSystem.get(conf);
        
        // 打开HDFS文件的输入流
        FSDataInputStream in = fs.open(new Path("/path/to/file.txt"));
        
        // 读取文件内容
        byte[] buffer = new byte[1024];
        int bytesRead;
        while ((bytesRead = in.read(buffer)) != -1) {
            // 处理读取的数据
            // ...
        }

        // 判断文件是否读取完毕
        if (in.available() == 0) {
            System.out.println("文件已读取完毕");
        } else {
            System.out.println("文件未读取完毕");
        }
        
        // 关闭输入流
        in.close();
        // 关闭文件系统
        fs.close();
    }
}

在上述示例中，while循环用于读取文件内容，当read()方法返回-1时表示文件已经读取完毕。然后使用available()方法来判断文件是否读取完毕，如果返回值为0，则输出"文件已读取完毕"，否则输出"文件未读取完毕"