diff options
author | Aditya Kishore <aditya@maprtech.com> | 2014-09-09 13:26:06 -0700 |
---|---|---|
committer | Aditya Kishore <aditya@maprtech.com> | 2014-09-11 19:24:11 -0700 |
commit | 39990292e833bbfb419565a3503312c552110378 (patch) | |
tree | 6c1e527a082b7801162fa727b8a5d26f06c6072f /exec/java-exec/src/test/java/org/apache/drill/exec/store/CachedSingleFileSystem.java | |
parent | 20d2aa46e2b789d5fe09b1383ec559b4aa8f5316 (diff) |
DRILL-634: Cleanup/organize Java imports and trailing whitespaces from Drill code
Diffstat (limited to 'exec/java-exec/src/test/java/org/apache/drill/exec/store/CachedSingleFileSystem.java')
-rw-r--r-- | exec/java-exec/src/test/java/org/apache/drill/exec/store/CachedSingleFileSystem.java | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/store/CachedSingleFileSystem.java b/exec/java-exec/src/test/java/org/apache/drill/exec/store/CachedSingleFileSystem.java index 46a278583..6d6baf4e1 100644 --- a/exec/java-exec/src/test/java/org/apache/drill/exec/store/CachedSingleFileSystem.java +++ b/exec/java-exec/src/test/java/org/apache/drill/exec/store/CachedSingleFileSystem.java @@ -42,7 +42,7 @@ public class CachedSingleFileSystem extends FileSystem{ private ByteBuf file; private String path; - + public CachedSingleFileSystem(String path) throws IOException{ this.path = path; File f = new File(path); @@ -59,11 +59,12 @@ public class CachedSingleFileSystem extends FileSystem{ } } + @Override public void close() throws IOException{ file.release(); super.close(); } - + @Override public FSDataOutputStream append(Path arg0, int arg1, Progressable arg2) throws IOException { throw new UnsupportedOperationException(); @@ -125,14 +126,14 @@ public class CachedSingleFileSystem extends FileSystem{ public void setWorkingDirectory(Path arg0) { throw new UnsupportedOperationException(); } - - + + private class CachedFSDataInputStream extends ByteBufInputStream implements Seekable, PositionedReadable{ private ByteBuf buf; public CachedFSDataInputStream(ByteBuf buffer) { super(buffer); this.buf = buffer; - + } @Override |