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 <eric.new...@gmail.com> Authored: Tue Jun 10 16:53:24 2014 -0400 Committer: Eric C. Newton <eric.new...@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);
