| commit | ecbb73fd6e9ec9737b9db5d822b5e2c97638a366 | [log] [tgz] |
|---|---|---|
| author | Murtadha Hubail <mhubail@apache.org> | Fri Aug 31 04:06:01 2018 +0300 |
| committer | Murtadha Hubail <mhubail@apache.org> | Thu Aug 30 23:34:46 2018 -0700 |
| tree | 6b3714a1b9db5de8158769d39da5b2fb4321c20c | |
| parent | 8c88975a781cd2b384da31bcd59aad2e26480e3e [diff] |
[NO ISSUE][STO] Add API to Get Total Disk Usage - user model changes: no - storage format changes: no - interface changes: yes Details: - Add new API to get total disk usage of all NC io devices. Change-Id: Iba1538205dbadefdddd8b50be6373dbe7525d0ef Reviewed-on: https://asterix-gerrit.ics.uci.edu/2943 Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Reviewed-by: Till Westmann <tillw@apache.org> Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
diff --git a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/io/IIOManager.java b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/io/IIOManager.java index ff1e47f..962f826 100644 --- a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/io/IIOManager.java +++ b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/io/IIOManager.java
@@ -97,4 +97,11 @@ * @throws HyracksDataException */ FileReference createWorkspaceFile(String prefix) throws HyracksDataException; + + /** + * Gets the total disk usage in bytes of this {@link IIOManager} io devices handles. + * + * @return the total disk usage in bytes + */ + long getTotalDiskUsage(); }
diff --git a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/io/IOManager.java b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/io/IOManager.java index d13ca8d..b5cb21a 100644 --- a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/io/IOManager.java +++ b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/io/IOManager.java
@@ -36,6 +36,7 @@ import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; +import org.apache.commons.io.FileUtils; import org.apache.hyracks.api.exceptions.ErrorCode; import org.apache.hyracks.api.exceptions.HyracksDataException; import org.apache.hyracks.api.io.FileReference; @@ -416,4 +417,13 @@ Thread.currentThread().interrupt(); } } + + @Override + public long getTotalDiskUsage() { + long totalSize = 0; + for (IODeviceHandle handle : ioDevices) { + totalSize += FileUtils.sizeOfDirectory(handle.getMount()); + } + return totalSize; + } }