You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2014/04/15 06:40:52 UTC

[1/3] git commit: ACCUMULO-2668 Override the write method which takes a byte[] to call the efficient method on the wrapped OutputStream

Repository: accumulo
Updated Branches:
  refs/heads/1.6.0-SNAPSHOT 126b6482a -> e4cef7f20
  refs/heads/master 0f0acb68b -> cffb86de6


ACCUMULO-2668 Override the write method which takes a byte[] to call the efficient method on the wrapped OutputStream

FilterOutputStream's implementation for this write method is horribly inefficient,
and causes a massive degradation in ingest performance.

Signed-off-by: Josh Elser <el...@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/e4cef7f2
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/e4cef7f2
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/e4cef7f2

Branch: refs/heads/1.6.0-SNAPSHOT
Commit: e4cef7f209551ebe17e43058e182ca22f8f89293
Parents: 126b648
Author: Jonathan Park <pa...@gmail.com>
Authored: Tue Apr 15 00:37:21 2014 -0400
Committer: Josh Elser <el...@apache.org>
Committed: Tue Apr 15 00:40:10 2014 -0400

----------------------------------------------------------------------
 .../accumulo/core/security/crypto/NoFlushOutputStream.java     | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/e4cef7f2/core/src/main/java/org/apache/accumulo/core/security/crypto/NoFlushOutputStream.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/security/crypto/NoFlushOutputStream.java b/core/src/main/java/org/apache/accumulo/core/security/crypto/NoFlushOutputStream.java
index a68bdfd..2f9f4bb 100644
--- a/core/src/main/java/org/apache/accumulo/core/security/crypto/NoFlushOutputStream.java
+++ b/core/src/main/java/org/apache/accumulo/core/security/crypto/NoFlushOutputStream.java
@@ -17,6 +17,7 @@
 package org.apache.accumulo.core.security.crypto;
 
 import java.io.FilterOutputStream;
+import java.io.IOException;
 import java.io.OutputStream;
 
 public class NoFlushOutputStream extends FilterOutputStream {
@@ -26,6 +27,11 @@ public class NoFlushOutputStream extends FilterOutputStream {
   }
 
   @Override
+  public void write(byte[] b, int off, int len) throws IOException {
+    out.write(b, off, len);
+  }
+
+  @Override
   public void flush() {}
 
 }


[2/3] git commit: ACCUMULO-2668 Override the write method which takes a byte[] to call the efficient method on the wrapped OutputStream

Posted by el...@apache.org.
ACCUMULO-2668 Override the write method which takes a byte[] to call the efficient method on the wrapped OutputStream

FilterOutputStream's implementation for this write method is horribly inefficient,
and causes a massive degradation in ingest performance.

Signed-off-by: Josh Elser <el...@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/e4cef7f2
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/e4cef7f2
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/e4cef7f2

Branch: refs/heads/master
Commit: e4cef7f209551ebe17e43058e182ca22f8f89293
Parents: 126b648
Author: Jonathan Park <pa...@gmail.com>
Authored: Tue Apr 15 00:37:21 2014 -0400
Committer: Josh Elser <el...@apache.org>
Committed: Tue Apr 15 00:40:10 2014 -0400

----------------------------------------------------------------------
 .../accumulo/core/security/crypto/NoFlushOutputStream.java     | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/e4cef7f2/core/src/main/java/org/apache/accumulo/core/security/crypto/NoFlushOutputStream.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/security/crypto/NoFlushOutputStream.java b/core/src/main/java/org/apache/accumulo/core/security/crypto/NoFlushOutputStream.java
index a68bdfd..2f9f4bb 100644
--- a/core/src/main/java/org/apache/accumulo/core/security/crypto/NoFlushOutputStream.java
+++ b/core/src/main/java/org/apache/accumulo/core/security/crypto/NoFlushOutputStream.java
@@ -17,6 +17,7 @@
 package org.apache.accumulo.core.security.crypto;
 
 import java.io.FilterOutputStream;
+import java.io.IOException;
 import java.io.OutputStream;
 
 public class NoFlushOutputStream extends FilterOutputStream {
@@ -26,6 +27,11 @@ public class NoFlushOutputStream extends FilterOutputStream {
   }
 
   @Override
+  public void write(byte[] b, int off, int len) throws IOException {
+    out.write(b, off, len);
+  }
+
+  @Override
   public void flush() {}
 
 }


[3/3] git commit: Merge branch '1.6.0-SNAPSHOT'

Posted by el...@apache.org.
Merge branch '1.6.0-SNAPSHOT'


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/cffb86de
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/cffb86de
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/cffb86de

Branch: refs/heads/master
Commit: cffb86de6145c19db87c5f7a947aa053cee9fd78
Parents: 0f0acb6 e4cef7f
Author: Josh Elser <el...@apache.org>
Authored: Tue Apr 15 00:40:31 2014 -0400
Committer: Josh Elser <el...@apache.org>
Committed: Tue Apr 15 00:40:31 2014 -0400

----------------------------------------------------------------------
 .../accumulo/core/security/crypto/NoFlushOutputStream.java     | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------