You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by na...@apache.org on 2012/12/12 17:39:59 UTC
svn commit: r1420817 -
/hive/trunk/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java
Author: namit
Date: Wed Dec 12 16:39:58 2012
New Revision: 1420817
URL: http://svn.apache.org/viewvc?rev=1420817&view=rev
Log:
HIVE-3793 Print number of fetched rows after query in CliDriver
(Navis via namit)
Modified:
hive/trunk/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java
Modified: hive/trunk/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java
URL: http://svn.apache.org/viewvc/hive/trunk/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java?rev=1420817&r1=1420816&r2=1420817&view=diff
==============================================================================
--- hive/trunk/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java (original)
+++ hive/trunk/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java Wed Dec 12 16:39:58 2012
@@ -266,11 +266,13 @@ public class CliDriver {
printHeader(qp, out);
+ int counter = 0;
try {
while (qp.getResults(res)) {
for (String r : res) {
out.println(r);
}
+ counter += res.size();
res.clear();
if (out.checkError()) {
break;
@@ -289,10 +291,9 @@ public class CliDriver {
}
long end = System.currentTimeMillis();
- if (end > start) {
- double timeTaken = (end - start) / 1000.0;
- console.printInfo("Time taken: " + timeTaken + " seconds", null);
- }
+ double timeTaken = (end - start) / 1000.0;
+ console.printInfo("Time taken: " + timeTaken + " seconds" +
+ (counter == 0 ? "" : ", Fetched: " + counter + " row(s)"));
} else {
String firstToken = tokenizeCmd(cmd.trim())[0];