java - Hadoop 文件系统 : getUsed

Question

我正在尝试使用 FileSystem 类中的 getUsed() 函数:

Configuration l_configuration = new Configuration();

l_configuration.set("fs.default.name", "hdfs://localhost:9100");
l_configuration.set("mapred.job.tracker", "localhost:9101");
l_configuration.setBoolean("fs.hdfs.impl.disable.cache", true);

FileSystem l_fileSystem = FileSystem.get(l_configuration);

long size = 0;
size = l_fileSystem.getUsed();

System.out.println("Total size : "+size); // Total size : 0

但我肯定在我的 HDFS 中有一些文件。如果我执行以下命令 shell:

$ hadoop dfs -dus
hdfs://localhost:9100/user/xxx/yyy  358873405

如何使用getUsed()函数？

Answer 1

您需要考虑 DistributedFileSystem 而不是 FileSystem 才能正确获取大小。

将以下替换为，

FileSystem l_fileSystem = FileSystem.get(l_configuration);

long size = 0;
size = l_fileSystem.getUsed();

有了这个，

DistributedFileSystem l_fileSystem = (DistributedFileSystem) DistributedFileSystem.get(l_configuration);

long size = 0;
size = l_fileSystem.getDiskStatus().getUsed();