java: 不兼容的类型: org.apache.hadoop.fs.FileStatus[]无法转换为org.apache.hadoop.fs.Path[]

这个错误通常发生在使用 Hadoop 文件系统 API 时，因为方法期望一个 Path 数组，但是你传入了一个 FileStatus 数组。解决这个问题的方法是将 FileStatus 数组转换为 Path 数组，可以使用 Java 8 中提供的流式 API 来完成这个操作。具体代码如下：

FileStatus[] fileStatuses = ...;
Path[] paths = Arrays.stream(fileStatuses).map(FileStatus::getPath).toArray(Path[]::new);

这个代码将 FileStatus 数组转换为 Path 数组，可以解决你遇到的这个问题。

相关问题

org.apache.hadoop.fs.FileStatus 方法详细说明

org.apache.hadoop.fs.FileStatus类是Hadoop中用于表示文件或目录状态的类。它包含了文件或目录的元数据信息，例如文件大小、修改时间、访问权限等。

该类提供了以下方法：

1. long getAccessTime()：获取文件或目录的最后访问时间，返回一个long类型的时间戳。

2. short getBlockReplication()：获取文件的副本数，如果是目录则返回0。

3. long getBlockSize()：获取文件的块大小，如果是目录则返回0。

4. String getGroup()：获取文件或目录所属组。

5. long getLen()：获取文件长度。

6. long getModificationTime()：获取文件或目录的最后修改时间，返回一个long类型的时间戳。

7. Path getPath()：获取文件或目录的路径。

8. FsPermission getPermission()：获取文件或目录的权限。

9. String getOwner()：获取文件或目录的所有者。

10. boolean isDirectory()：判断是否是一个目录。

11. boolean isFile()：判断是否是一个文件。

12. boolean isSymlink()：判断是否是一个符号链接。

13. Path getSymlink()：获取符号链接的目标路径，如果不是符号链接则返回null。

除此之外，该类还有一个构造方法和一个toString()方法，用于创建对象和将对象以字符串形式输出。

hadoop fileStatus 返回不包含hdfs://namenode:port的路径

如果你使用的是 `FileStatus` 类的 `getPath()` 方法获取文件路径，那么在 HDFS 中返回的路径格式应该是 `hdfs://<namenode>:<port>/<path>`，而在本地文件系统中返回的路径格式应该是 `file:///path` 或 `file:/path`。

如果你使用 `FileStatus` 类的 `getPath().toUri().getPath()` 方法获取文件路径，那么返回的路径将不包含 `hdfs://namenode:port` 或 `file://` 前缀，只包含文件路径本身。这是因为 `toUri().getPath()` 方法只返回 URI 的路径部分，并去掉了协议部分。

下面是一个示例代码，演示如何获取 HDFS 文件和本地文件的路径：

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

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

public class FileStatusExample {
    public static void main(String[] args) throws IOException, URISyntaxException {
        // HDFS 文件路径
        String hdfsPath = "hdfs://namenode:port/user/hadoop/example.txt";
        // 本地文件路径
        String localPath = "file:///home/user/example.txt";

        Configuration conf = new Configuration();
        FileSystem fs = FileSystem.get(new URI(hdfsPath), conf);

        // 获取 HDFS 文件状态
        Path hdfsFile = new Path(hdfsPath);
        FileStatus hdfsStatus = fs.getFileStatus(hdfsFile);
        System.out.println("HDFS 文件路径：" + hdfsStatus.getPath()); // hdfs://namenode:port/user/hadoop/example.txt
        System.out.println("HDFS 文件路径（不包含前缀）：" + hdfsStatus.getPath().toUri().getPath()); // /user/hadoop/example.txt

        // 获取本地文件状态
        Path localFile = new Path(localPath);
        FileStatus localStatus = fs.getFileStatus(localFile);
        System.out.println("本地文件路径：" + localStatus.getPath()); // file:/home/user/example.txt
        System.out.println("本地文件路径（不包含前缀）：" + localStatus.getPath().toUri().getPath()); // /home/user/example.txt

        fs.close();
    }
}