accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ctubb...@apache.org
Subject [05/12] accumulo git commit: ACCUMULO-3515 Make SplitLarge respect maxSize flag
Date Fri, 23 Jan 2015 22:26:51 GMT
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.6
Commit: a27a0bb9bcc971e258e77b9fc42cb714deb4bf47
Parents: 9d479e2
Author: Christopher Tubbs <ctubbsii@apache.org>
Authored: Fri Jan 23 16:24:45 2015 -0500
Committer: Christopher Tubbs <ctubbsii@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);


Mime
View raw message