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/master Commit: a27a0bb9bcc971e258e77b9fc42cb714deb4bf47 Parents: 9d479e2 Author: Christopher Tubbs <ctubb...@apache.org> Authored: Fri Jan 23 16:24:45 2015 -0500 Committer: Christopher Tubbs <ctubb...@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);
