accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject svn commit: r1309586 - in /accumulo/trunk: server/src/main/java/org/apache/accumulo/server/test/continuous/GenSplits.java test/system/continuous/README
Date Wed, 04 Apr 2012 20:41:25 GMT
Author: kturner
Date: Wed Apr  4 20:41:24 2012
New Revision: 1309586

URL: http://svn.apache.org/viewvc?rev=1309586&view=rev
Log:
ACCUMULO-515 Added utility to generate split points for continuous ingest.

Added:
    accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/continuous/GenSplits.java
Modified:
    accumulo/trunk/test/system/continuous/README

Added: accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/continuous/GenSplits.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/continuous/GenSplits.java?rev=1309586&view=auto
==============================================================================
--- accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/continuous/GenSplits.java
(added)
+++ accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/continuous/GenSplits.java
Wed Apr  4 20:41:24 2012
@@ -0,0 +1,52 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.accumulo.server.test.continuous;
+
+/**
+ * 
+ */
+public class GenSplits {
+  public static void main(String[] args) {
+    
+    if (args.length != 1) {
+      System.err.println("Usage: " + GenSplits.class.getName() + " <num tablets>");
+      System.exit(-1);
+    }
+    
+    int numTablets = Integer.parseInt(args[0]);
+    
+    if (numTablets < 1) {
+      System.err.println("ERROR: numTablets < 1");
+      System.exit(-1);
+    }
+    
+    int numSplits = numTablets - 1;
+    long distance = (Long.MAX_VALUE / numTablets) + 1;
+    long split = distance;
+    for (int i = 0; i < numSplits; i++) {
+      
+      String s = String.format("%016x", split);
+      
+      while (s.charAt(s.length() - 1) == '0') {
+        s = s.substring(0, s.length() - 1);
+      }
+      
+      System.out.println(s);
+      split += distance;
+    }
+  }
+}

Modified: accumulo/trunk/test/system/continuous/README
URL: http://svn.apache.org/viewvc/accumulo/trunk/test/system/continuous/README?rev=1309586&r1=1309585&r2=1309586&view=diff
==============================================================================
--- accumulo/trunk/test/system/continuous/README (original)
+++ accumulo/trunk/test/system/continuous/README Wed Apr  4 20:41:24 2012
@@ -5,6 +5,8 @@ statistics in order to understand how ac
 copy all of the .example files and modify them.  These scripts rely on pssh.
 Before running any script you may need to use pssh to create the log directory on
 each machine if you want it local.  Also, create the table "ci" before running.
+You can run org.apache.accumulo.server.test.continuous.GenSplits to generate
+splits points for a continuous ingest table.
 
 The following ingest scripts inserts data into accumulo that will form a random
 graph.



Mime
View raw message