sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cheol...@apache.org
Subject [2/2] git commit: SQOOP-907: Print out queries executed by Sqoop on mapreduce job side
Date Sat, 02 Mar 2013 00:25:45 GMT
Updated Branches:
  refs/heads/trunk 4aa174abe -> f4d5ed537


SQOOP-907: Print out queries executed by Sqoop on mapreduce job side

(Jarcec Cecho via Cheolsoo Park)


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

Branch: refs/heads/trunk
Commit: f4d5ed5375a7c4f94646ae0faa815b63ad641343
Parents: 1d9339d
Author: Cheolsoo Park <cheolsoo@apache.org>
Authored: Fri Mar 1 16:20:10 2013 -0800
Committer: Cheolsoo Park <cheolsoo@apache.org>
Committed: Fri Mar 1 16:20:10 2013 -0800

----------------------------------------------------------------------
 .../apache/sqoop/mapreduce/db/DBRecordReader.java  |    3 ++-
 .../mapreduce/db/DataDrivenDBInputFormat.java      |    5 +++++
 2 files changed, 7 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/sqoop/blob/f4d5ed53/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java b/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java
index 4c03c0d..ab8bf18 100644
--- a/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java
+++ b/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java
@@ -107,7 +107,7 @@ public class DBRecordReader<T extends DBWritable> extends
       statement.setFetchSize(fetchSize);
     }
 
-    LOG.debug("Executing query: " + query);
+    LOG.info("Executing query: " + query);
     return statement.executeQuery();
   }
 
@@ -233,6 +233,7 @@ public class DBRecordReader<T extends DBWritable> extends
       }
       if (null == this.results) {
         // First time into this method, run the query.
+        LOG.info("Working on split: " + split);
         this.results = executeQuery(getSelectQuery());
       }
       if (!results.next()) {

http://git-wip-us.apache.org/repos/asf/sqoop/blob/f4d5ed53/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java b/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java
index 140517a..81677d7 100644
--- a/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java
+++ b/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java
@@ -352,6 +352,11 @@ public class DataDrivenDBInputFormat<T extends DBWritable>
     public String getUpperClause() {
       return upperBoundClause;
     }
+
+    @Override
+    public String toString() {
+      return this.lowerBoundClause + " AND " + this.upperBoundClause;
+    }
   }
 
 }


Mime
View raw message