DRILL-377: Use BufferedInputStream in SpoolingRawBatchBuffer to improve performance
Signed-off-by: Jacques Nadeau <[email protected]> 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 <[email protected]> Authored: Thu Feb 13 00:36:59 2014 -0800 Committer: Jacques Nadeau <[email protected]> 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
