drill-dev mailing list archives

DRILL-377: Use BufferedInputStream in SpoolingRawBatchBuffer to improve performance

Signed-off-by: Jacques Nadeau <jacques@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/7f7b6be2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/7f7b6be2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/7f7b6be2

Branch: refs/heads/master
Commit: 7f7b6be21af3e2744b4ee867e5da4488f526037b
Parents: ad3ac80
Author: Steven Phillips <sphillips@maprtech.com>
Authored: Thu Feb 13 00:36:59 2014 -0800
Committer: Jacques Nadeau <jacques@apache.org>
Committed: Mon Mar 3 23:22:17 2014 -0800

----------------------------------------------------------------------
 .../org/apache/drill/exec/store/LocalSyncableFileSystem.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/7f7b6be2/exec/java-exec/src/main/java/org/apache/drill/exec/store/LocalSyncableFileSystem.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/LocalSyncableFileSystem.java
b/exec/java-exec/src/main/java/org/apache/drill/exec/store/LocalSyncableFileSystem.java
index 10a4dc5..8d525f3 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/LocalSyncableFileSystem.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/LocalSyncableFileSystem.java
@@ -136,10 +136,10 @@ public class LocalSyncableFileSystem extends FileSystem {
 
   public class LocalInputStream extends InputStream implements Seekable, PositionedReadable
{
 
-    private FileInputStream input;
+    private BufferedInputStream input;
 
     public LocalInputStream(Path path)  throws IOException {
-      input = new FileInputStream(path.toString());
+      input = new BufferedInputStream(new FileInputStream(path.toString()), 1024*1024);
     }
 
     @Override