contrib: hadoop: return the last used OSD as the current datanode

xtreemfs · Oct 28, 2016 · 93cf13d · 93cf13d
1 parent ec6b102
commit 93cf13d
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/contrib/hadoop/src/main/java/org/xtreemfs/common/clients/hadoop/XtreemFSInputStream.java b/contrib/hadoop/src/main/java/org/xtreemfs/common/clients/hadoop/XtreemFSInputStream.java
@@ -139,6 +139,12 @@ public synchronized void close() throws IOException {
         fileHandle.close();
         closed = true;
     }
+
+    // For use by external systems, such as the StatisticsFileSystem
+    // https://github.com/robert-schmidtke/hdfs-statistics-adapter
+    public String getCurrentDatanodeHostName() {
+        return fileHandle.getLastOSDAddress();
+    }
 
     private int readFromBuffer(byte[] bytes, int offset, int length) throws IOException {
         if (EOF || length == 0) {