You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ct...@apache.org on 2015/01/23 23:26:50 UTC
[04/12] accumulo git commit: ACCUMULO-3515 Make SplitLarge respect
maxSize flag
ACCUMULO-3515 Make SplitLarge respect maxSize flag
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/a27a0bb9
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/a27a0bb9
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/a27a0bb9
Branch: refs/heads/1.5
Commit: a27a0bb9bcc971e258e77b9fc42cb714deb4bf47
Parents: 9d479e2
Author: Christopher Tubbs <ct...@apache.org>
Authored: Fri Jan 23 16:24:45 2015 -0500
Committer: Christopher Tubbs <ct...@apache.org>
Committed: Fri Jan 23 16:24:45 2015 -0500
----------------------------------------------------------------------
.../main/java/org/apache/accumulo/core/file/rfile/SplitLarge.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/a27a0bb9/core/src/main/java/org/apache/accumulo/core/file/rfile/SplitLarge.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/file/rfile/SplitLarge.java b/core/src/main/java/org/apache/accumulo/core/file/rfile/SplitLarge.java
index 95bf097..79ef8cb 100644
--- a/core/src/main/java/org/apache/accumulo/core/file/rfile/SplitLarge.java
+++ b/core/src/main/java/org/apache/accumulo/core/file/rfile/SplitLarge.java
@@ -52,7 +52,6 @@ public class SplitLarge {
public static void main(String[] args) throws Exception {
Configuration conf = CachedConfiguration.getInstance();
FileSystem fs = FileSystem.get(conf);
- long maxSize = 10 * 1024 * 1024;
Opts opts = new Opts();
opts.parseArgs(SplitLarge.class.getName(), args);
@@ -77,7 +76,7 @@ public class SplitLarge {
while (iter.hasTop()) {
Key key = iter.getTopKey();
Value value = iter.getTopValue();
- if (key.getSize() + value.getSize() < maxSize) {
+ if (key.getSize() + value.getSize() < opts.maxSize) {
small.append(key, value);
} else {
large.append(key, value);