/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/protocol/ |
H A D | StorageReport.java | 27 private final long dfsUsed; field in StorageReport 34 long capacity, long dfsUsed, long remaining, long bpUsed) { in StorageReport() argument 38 this.dfsUsed = dfsUsed; in StorageReport() 56 return dfsUsed; in getDfsUsed()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocol/ |
H A D | DatanodeInfo.java | 46 private long dfsUsed; field in DatanodeInfo 89 this.dfsUsed = from.getDfsUsed(); in DatanodeInfo() 104 this.dfsUsed = 0L; in DatanodeInfo() 121 final long capacity, final long dfsUsed, final long remaining, in DatanodeInfo() argument 136 final long capacity, final long dfsUsed, final long remaining, in DatanodeInfo() argument 144 this.dfsUsed = dfsUsed; in DatanodeInfo() 166 public long getDfsUsed() { return dfsUsed; } in getDfsUsed() 173 long nonDFSUsed = capacity - dfsUsed - remaining; in getNonDfsUsed() 179 return DFSUtil.getPercentUsed(dfsUsed, capacity); in getDfsUsedPercent() 260 public void setDfsUsed(long dfsUsed) { in setDfsUsed() argument [all …]
|
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/protocol/ |
H A D | DatanodeInfo.java | 42 protected long dfsUsed; field in DatanodeInfo 66 this.dfsUsed = from.getDfsUsed(); in DatanodeInfo() 78 this.dfsUsed = 0L; in DatanodeInfo() 94 final long capacity, final long dfsUsed, final long remaining, in DatanodeInfo() argument 101 this.dfsUsed = dfsUsed; in DatanodeInfo() 114 public long getDfsUsed() { return dfsUsed; } in getDfsUsed() 118 long nonDFSUsed = capacity - dfsUsed - remaining; in getNonDfsUsed() 128 return ((float)dfsUsed * 100.0f)/(float)capacity; in getDfsUsedPercent() 369 out.writeLong(dfsUsed); in write() 386 this.dfsUsed = in.readLong(); in readFields()
|
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/namenode/ |
H A D | DatanodeDescriptor.java | 166 long dfsUsed, in DatanodeDescriptor() argument 170 updateHeartbeat(capacity, dfsUsed, remaining, xceiverCount); in DatanodeDescriptor() 186 long dfsUsed, in DatanodeDescriptor() argument 190 updateHeartbeat(capacity, dfsUsed, remaining, xceiverCount); in DatanodeDescriptor() 225 this.dfsUsed = 0; in resetBlocks() 237 void updateHeartbeat(long capacity, long dfsUsed, long remaining, in updateHeartbeat() argument 240 this.dfsUsed = dfsUsed; in updateHeartbeat() 458 this.dfsUsed = in.readLong(); in readFieldsFromFSEditLog()
|
H A D | NameNode.java | 1079 long dfsUsed, in sendHeartbeat() argument 1084 return namesystem.handleHeartbeat(nodeReg, capacity, dfsUsed, remaining, in sendHeartbeat()
|
H A D | FSNamesystem.java | 3023 long capacity, long dfsUsed, long remaining, in handleHeartbeat() argument 3046 nodeinfo.updateHeartbeat(capacity, dfsUsed, remaining, xceiverCount); in handleHeartbeat()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ |
H A D | DatanodeStorageInfo.java | 111 private long dfsUsed; field in DatanodeStorageInfo 177 public void setUtilizationForTesting(long capacity, long dfsUsed, in setUtilizationForTesting() argument 180 this.dfsUsed = dfsUsed; in setUtilizationForTesting() 218 return dfsUsed; in getDfsUsed() 293 dfsUsed = r.getDfsUsed(); in updateState() 333 false, capacity, dfsUsed, remaining, blockPoolUsed); in toStorageReport()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/ |
H A D | BalancingPolicy.java | 114 long dfsUsed = 0L; in getUtilization() local 118 dfsUsed += s.getDfsUsed(); in getUtilization() 121 return capacity == 0L? null: dfsUsed*100.0/capacity; in getUtilization()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ |
H A D | FsVolumeList.java | 130 long dfsUsed = 0L; in getDfsUsed() local 133 dfsUsed += v.getDfsUsed(); in getDfsUsed() 138 return dfsUsed; in getDfsUsed() 142 long dfsUsed = 0L; in getBlockPoolUsed() local 145 dfsUsed += v.getBlockPoolUsed(bpid); in getBlockPoolUsed() 150 return dfsUsed; in getBlockPoolUsed()
|
H A D | FsVolumeImpl.java | 294 long dfsUsed = 0; in getDfsUsed() local 297 dfsUsed += s.getDfsUsed(); in getDfsUsed() 300 return dfsUsed; in getDfsUsed()
|
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/ |
H A D | DistributedFileSystem.java | 385 private long dfsUsed; field in DistributedFileSystem.DiskStatus 387 public DiskStatus(long capacity, long dfsUsed, long remaining) { in DiskStatus() argument 389 this.dfsUsed = dfsUsed; in DiskStatus() 397 return dfsUsed; in getDfsUsed()
|
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/protocol/ |
H A D | DatanodeProtocol.java | 90 long dfsUsed, long remaining, in sendHeartbeat() argument
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/ |
H A D | TestReplicationPolicy.java | 95 long capacity, long dfsUsed, long remaining, long blockPoolUsed, in updateHeartbeatWithUsage() argument 98 capacity, dfsUsed, remaining, blockPoolUsed); in updateHeartbeatWithUsage() 105 long dfsUsed, long remaining, long blockPoolUsed) { in updateHeartbeatForExtraStorage() argument 108 capacity, dfsUsed, remaining, blockPoolUsed); in updateHeartbeatForExtraStorage()
|
H A D | TestReplicationPolicyWithNodeGroup.java | 181 long capacity, long dfsUsed, long remaining, long blockPoolUsed, in updateHeartbeatWithUsage() argument 185 capacity, dfsUsed, remaining, blockPoolUsed); in updateHeartbeatWithUsage()
|
/dports/net/rclone/rclone-1.57.0/vendor/github.com/colinmarc/hdfs/v2/internal/protocol/hadoop_hdfs/ |
H A D | hdfs.proto | 85 optional uint64 dfsUsed = 3 [default = 0]; field 122 optional uint64 dfsUsed = 4 [ default = 0 ]; field
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/proto/ |
H A D | hdfs.proto | 85 optional uint64 dfsUsed = 3 [default = 0]; 121 optional uint64 dfsUsed = 4 [ default = 0 ];
|
H A D | DatanodeProtocol.proto | 176 * dfsUsed - storage used by HDFS
|
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/datanode/ |
H A D | FSDataset.java | 677 long dfsUsed = 0L; in getDfsUsed() local 679 dfsUsed += volumes[idx].getDfsUsed(); in getDfsUsed() 681 return dfsUsed; in getDfsUsed()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/ |
H A D | DistributedFileSystem.java | 1102 public DiskStatus(long capacity, long dfsUsed, long remaining) { 1103 super(capacity, dfsUsed, remaining);
|