accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [1/3] git commit: ACCUMULO-2888 set the threads in the BatchWriterConfig
Date Tue, 10 Jun 2014 20:55:16 GMT
Repository: accumulo
Updated Branches:
  refs/heads/master 8ce0b687f -> 05583b179


ACCUMULO-2888 set the threads in the BatchWriterConfig


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

Branch: refs/heads/master
Commit: 53ec68999a416d96a0bd3c8d92a6311c8b69987b
Parents: 1e0d50e
Author: Eric C. Newton <eric.newton@gmail.com>
Authored: Tue Jun 10 16:53:24 2014 -0400
Committer: Eric C. Newton <eric.newton@gmail.com>
Committed: Tue Jun 10 16:53:24 2014 -0400

----------------------------------------------------------------------
 .../src/main/java/org/apache/accumulo/core/cli/BatchWriterOpts.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/53ec6899/core/src/main/java/org/apache/accumulo/core/cli/BatchWriterOpts.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/cli/BatchWriterOpts.java b/core/src/main/java/org/apache/accumulo/core/cli/BatchWriterOpts.java
index cfd37f2..45a1bc7 100644
--- a/core/src/main/java/org/apache/accumulo/core/cli/BatchWriterOpts.java
+++ b/core/src/main/java/org/apache/accumulo/core/cli/BatchWriterOpts.java
@@ -41,6 +41,7 @@ public class BatchWriterOpts {
   
   public BatchWriterConfig getBatchWriterConfig() {
     BatchWriterConfig config = new BatchWriterConfig();
+    config.setMaxWriteThreads(this.batchThreads);
     config.setMaxLatency(this.batchLatency, TimeUnit.MILLISECONDS);
     config.setMaxMemory(this.batchMemory);
     config.setTimeout(this.batchTimeout, TimeUnit.MILLISECONDS);


Mime
View raw message