accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bus...@apache.org
Subject [3/6] git commit: ACCUMULO-2230 Make sure offline scan uses the cloned table.
Date Tue, 21 Jan 2014 18:25:18 GMT
ACCUMULO-2230 Make sure offline scan uses the cloned table.


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/a4384884
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/a4384884
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/a4384884

Branch: refs/heads/master
Commit: a43848849e78aa9bc6edb5d6d87e2a285d8fccf2
Parents: 78c5f46
Author: Sean Busbey <busbey@cloudera.com>
Authored: Mon Jan 20 23:30:01 2014 -0600
Committer: Sean Busbey <busbey@cloudera.com>
Committed: Tue Jan 21 11:52:14 2014 -0600

----------------------------------------------------------------------
 .../apache/accumulo/test/continuous/ContinuousVerify.java | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/a4384884/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousVerify.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousVerify.java
b/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousVerify.java
index 1ace774..08d8ff1 100644
--- a/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousVerify.java
+++ b/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousVerify.java
@@ -183,6 +183,9 @@ public class ContinuousVerify extends Configured implements Tool {
     Job job = new Job(getConf(), this.getClass().getSimpleName() + "_" + System.currentTimeMillis());
     job.setJarByClass(this.getClass());
     
+    job.setInputFormatClass(AccumuloInputFormat.class);
+    opts.setAccumuloConfigs(job);
+
     String clone = opts.getTableName();
     Connector conn = null;
     if (opts.scanOffline) {
@@ -191,13 +194,10 @@ public class ContinuousVerify extends Configured implements Tool {
       conn = opts.getConnector();
       conn.tableOperations().clone(opts.getTableName(), clone, true, new HashMap<String,String>(),
new HashSet<String>());
       conn.tableOperations().offline(clone);
+      AccumuloInputFormat.setInputTableName(job, clone);
+      AccumuloInputFormat.setOfflineTableScan(job, true);
     }
     
-    job.setInputFormatClass(AccumuloInputFormat.class);
-    
-    opts.setAccumuloConfigs(job);
-    AccumuloInputFormat.setOfflineTableScan(job, opts.scanOffline);
-    
     // set up ranges
     try {
       Set<Range> ranges = opts.getConnector().tableOperations().splitRangeByTablets(opts.getTableName(),
new Range(), opts.maxMaps);


Mime
View raw message