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/06/14 06:35:46 UTC
[05/50] [abbrv] git commit: ACCUMULO-2888 set the threads in the
BatchWriterConfig
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/ACCUMULO-378
Commit: 53ec68999a416d96a0bd3c8d92a6311c8b69987b
Parents: 1e0d50e
Author: Eric C. Newton <er...@gmail.com>
Authored: Tue Jun 10 16:53:24 2014 -0400
Committer: Eric C. Newton <er...@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);