accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [07/10] git commit: ACCUMULO-1783 Add some additional logging on AIF setup
Date Thu, 31 Oct 2013 03:25:19 GMT
ACCUMULO-1783 Add some additional logging on AIF setup


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

Branch: refs/heads/ACCUMULO-1783
Commit: 291b9392ae53b4e3943869e7b8041dc98560353b
Parents: ad03c51
Author: Josh Elser <elserj@apache.org>
Authored: Wed Oct 30 22:16:35 2013 -0400
Committer: Josh Elser <elserj@apache.org>
Committed: Wed Oct 30 22:16:35 2013 -0400

----------------------------------------------------------------------
 .../org/apache/accumulo/pig/AbstractAccumuloStorage.java    | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo-pig/blob/291b9392/src/main/java/org/apache/accumulo/pig/AbstractAccumuloStorage.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/accumulo/pig/AbstractAccumuloStorage.java b/src/main/java/org/apache/accumulo/pig/AbstractAccumuloStorage.java
index c2345cc..37efe84 100644
--- a/src/main/java/org/apache/accumulo/pig/AbstractAccumuloStorage.java
+++ b/src/main/java/org/apache/accumulo/pig/AbstractAccumuloStorage.java
@@ -208,11 +208,16 @@ public abstract class AbstractAccumuloStorage extends LoadFunc implements
StoreF
       AccumuloInputFormat.setInputInfo(conf, user, password.getBytes(), table, authorizations);
       AccumuloInputFormat.setZooKeeperInstance(conf, inst, zookeepers);
       if (columnFamilyColumnQualifierPairs.size() > 0) {
-        LOG.debug("columns: " + columnFamilyColumnQualifierPairs);
+        LOG.info("columns: " + columnFamilyColumnQualifierPairs);
         AccumuloInputFormat.fetchColumns(conf, columnFamilyColumnQualifierPairs);
       }
       
-      AccumuloInputFormat.setRanges(conf, Collections.singleton(new Range(start, end)));
+      Collection<Range> ranges = Collections.singleton(new Range(start, end));
+      
+      LOG.info("Scanning Accumulo for " + ranges);
+      
+      AccumuloInputFormat.setRanges(conf, ranges);
+      
       configureInputFormat(conf);
     }
   }


Mime
View raw message