You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by bi...@apache.org on 2012/10/17 07:20:53 UTC
svn commit: r1399100 - in /pig/branches/branch-0.11: CHANGES.txt
src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java
Author: billgraham
Date: Wed Oct 17 05:20:53 2012
New Revision: 1399100
URL: http://svn.apache.org/viewvc?rev=1399100&view=rev
Log:
PIG-2976: Reduce HBaseStorage logging (billgraham)
Modified:
pig/branches/branch-0.11/CHANGES.txt
pig/branches/branch-0.11/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java
Modified: pig/branches/branch-0.11/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.11/CHANGES.txt?rev=1399100&r1=1399099&r2=1399100&view=diff
==============================================================================
--- pig/branches/branch-0.11/CHANGES.txt (original)
+++ pig/branches/branch-0.11/CHANGES.txt Wed Oct 17 05:20:53 2012
@@ -24,6 +24,8 @@ INCOMPATIBLE CHANGES
PIG-1891 Enable StoreFunc to make intelligent decision based on job success or failure (initialcontext via gates)
IMPROVEMENTS
+PIG-2976: Reduce HBaseStorage logging (billgraham)
+
PIG-2947: Documentation for Rank operator (xalan via azaroth)
PIG-2943: DevTests, Refactor Windows checks to use new Util.WINDOWS method for code health (jgordon via dvryaboy)
Modified: pig/branches/branch-0.11/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.11/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java?rev=1399100&r1=1399099&r2=1399100&view=diff
==============================================================================
--- pig/branches/branch-0.11/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java (original)
+++ pig/branches/branch-0.11/src/org/apache/pig/backend/hadoop/hbase/HBaseStorage.java Wed Oct 17 05:20:53 2012
@@ -410,8 +410,8 @@ public class HBaseStorage extends LoadFu
if (colInfo.isColumnMap()) {
- if (LOG.isInfoEnabled()) {
- LOG.info("Adding family:prefix filters with values " +
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Adding family:prefix filters with values " +
Bytes.toString(colInfo.getColumnFamily()) + COLON +
Bytes.toString(colInfo.getColumnPrefix()));
}
@@ -425,8 +425,8 @@ public class HBaseStorage extends LoadFu
}
else {
- if (LOG.isInfoEnabled()) {
- LOG.info("Adding family:descriptor filters with values " +
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Adding family:descriptor filters with values " +
Bytes.toString(colInfo.getColumnFamily()) + COLON +
Bytes.toString(colInfo.getColumnName()));
}
@@ -446,8 +446,8 @@ public class HBaseStorage extends LoadFu
}
private void addRowFilter(CompareOp op, byte[] val) {
- if (LOG.isInfoEnabled()) {
- LOG.info("Adding filter " + op.toString() +
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Adding filter " + op.toString() +
" with value " + Bytes.toStringBinary(val));
}
addFilter(new RowFilter(op, new BinaryComparator(val)));