accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject svn commit: r1452491 - in /accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test: TestIngest.java VerifyIngest.java
Date Mon, 04 Mar 2013 20:33:21 GMT
Author: ecn
Date: Mon Mar  4 20:33:21 2013
New Revision: 1452491

URL: http://svn.apache.org/r1452491
Log:
ACCUMULO-745 fix Test/Verify ingest to work on wider rows

Modified:
    accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test/TestIngest.java
    accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test/VerifyIngest.java

Modified: accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test/TestIngest.java
URL: http://svn.apache.org/viewvc/accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test/TestIngest.java?rev=1452491&r1=1452490&r2=1452491&view=diff
==============================================================================
--- accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test/TestIngest.java (original)
+++ accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test/TestIngest.java Mon
Mar  4 20:33:21 2013
@@ -231,7 +231,7 @@ public class TestIngest {
         Mutation m = new Mutation(row);
         for (int j = 0; j < opts.cols; j++) {
           Text colf = new Text(opts.columnFamily);
-          Text colq = new Text(FastFormat.toZeroPaddedString(j, 5, 10, COL_PREFIX));
+          Text colq = new Text(FastFormat.toZeroPaddedString(j, 7, 10, COL_PREFIX));
           
           if (writer != null) {
             Key key = new Key(row, colf, colq, labBA);

Modified: accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test/VerifyIngest.java
URL: http://svn.apache.org/viewvc/accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test/VerifyIngest.java?rev=1452491&r1=1452490&r2=1452491&view=diff
==============================================================================
--- accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test/VerifyIngest.java (original)
+++ accumulo/branches/1.5/test/src/main/java/org/apache/accumulo/test/VerifyIngest.java Mon
Mar  4 20:33:21 2013
@@ -94,7 +94,7 @@ public class VerifyIngest {
         if (opts.useGet) {
           Text rowKey = new Text("row_" + String.format("%010d", expectedRow + opts.startRow));
           Text colf = new Text(opts.columnFamily);
-          Text colq = new Text("col_" + String.format("%05d", expectedCol));
+          Text colq = new Text("col_" + String.format("%07d", expectedCol));
           
           Scanner scanner = connector.createScanner("test_ingest", labelAuths);
           scanner.setBatchSize(1);
@@ -144,7 +144,7 @@ public class VerifyIngest {
           scanner.setBatchSize(scanOpts.scanBatchSize);
           scanner.setRange(new Range(startKey, endKey));
           for (int j = 0; j < opts.cols; j++) {
-            scanner.fetchColumn(new Text(opts.columnFamily), new Text("col_" + String.format("%05d",
j)));
+            scanner.fetchColumn(new Text(opts.columnFamily), new Text("col_" + String.format("%07d",
j)));
           }
           
           int recsReadBefore = recsRead;



Mime
View raw message