Override write(byte[] b, int off, int len) in FilterOutputStream for …

…better performance Closes #8748
elastic · Dec 2, 2014 · d8f1617 · d8f1617
1 parent 943dbb8
commit d8f1617
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/main/java/org/elasticsearch/common/blobstore/fs/FsBlobContainer.java b/src/main/java/org/elasticsearch/common/blobstore/fs/FsBlobContainer.java
@@ -89,6 +89,10 @@ public InputStream openInput(String name) throws IOException {
     public OutputStream createOutput(String blobName) throws IOException {
         final File file = new File(path, blobName);
         return new BufferedOutputStream(new FilterOutputStream(new FileOutputStream(file)) {
+
+            @Override // FilterOutputStream#write(byte[] b, int off, int len) is trappy writes every single byte
+            public void write(byte[] b, int off, int len) throws IOException { out.write(b, off, len);}
+
             @Override
             public void close() throws IOException {
                 super.close();