You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2013/10/31 04:25:19 UTC
[07/10] git commit: ACCUMULO-1783 Add some additional logging on AIF
setup
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 <el...@apache.org>
Authored: Wed Oct 30 22:16:35 2013 -0400
Committer: Josh Elser <el...@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);
}
}