如何获取出HDFS已用空间/总空间的值。java FileSystem中有相关的方法吗？？？ 10

回答后补追30悬赏... 回答后补追30悬赏展开

 我来答

2个回答

#合辑# 面试问优缺点怎么回答最加分？

_诗礼_
2015-01-26 · 超过69用户采纳过TA的回答

知道小有建树答主

回答量：184

采纳率：50%

帮助的人：108万

我也去答题访问个人页

关注

展开全部

    public List<BaseItem> getHdfsstatus() {
        if (conf == null) {
            conf = new Configuration();
            conf.set("fs.default.name","hdfs://CRNOPHQDW2:54310");
        }
        FileSystem fs = null;
        try {
            fs = FileSystem.get(conf);
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
        List<BaseItem> ret = new ArrayList<BaseItem>();
        DistributedFileSystem dfs = (DistributedFileSystem) fs;
        org.apache.hadoop.hdfs.DistributedFileSystem.DiskStatus ds = null;
        try {
            ds = dfs.getDiskStatus();
        } catch (IOException e) {
            e.printStackTrace();
        }
        long capacity = ds.getCapacity();
        long used = ds.getDfsUsed();
        long remaining = ds.getRemaining();
        long presentCapacity = used + remaining;
        String name = "GrobleStatus";
        String value = "GrobleValue";
        BaseItem bitem = new BaseItem(name, value);
        bitem.setMap_value("Configured Capacity"+getunittype(StringUtils.byteDesc(capacity)),
                getunitvalue(StringUtils.byteDesc(capacity)));
        bitem.setMap_value("Present Capacity"+getunittype(StringUtils.byteDesc(presentCapacity)),
                getunitvalue(StringUtils.byteDesc(presentCapacity)));
        bitem.setMap_value("DFS Remaining"+getunittype(StringUtils.byteDesc(remaining)), getunitvalue(StringUtils.byteDesc(remaining)));
        bitem.setMap_value("DFS Used"+getunittype(StringUtils.byteDesc(used)), getunitvalue(StringUtils.byteDesc(used)));
        bitem.setMap_value(
                "DFS Used%",
                StringUtils
                        .limitDecimalTo2(((1.0D * (double) used) / (double) presentCapacity) )
                        );
        ret.add(bitem);
        DatanodeInfo live[] = null;
        try {
            live = dfs
                    .getClient()
                    .datanodeReport(
                            org.apache.hadoop.hdfs.protocol.FSConstants.DatanodeReportType.LIVE);
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
        DatanodeInfo dead[] = null;
        try {
            dead = dfs
                    .getClient()
                    .datanodeReport(
                            org.apache.hadoop.hdfs.protocol.FSConstants.DatanodeReportType.DEAD);
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
        for (int i = 0; i < live.length; i++) {
            DatanodeInfo dn = live[i];
            ret.add(getbItem(dn));
        }

        for (int j = 0; j < dead.length; j++) {
            DatanodeInfo dn = dead[j];
            ret.add(getbItem(dn));
        }
        return ret;
    }