carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject [10/20] incubator-carbondata git commit: [CARBONDATA-137] Fixed detail limit query statistics issue (#904)
Date Sat, 06 Aug 2016 10:00:27 GMT
[CARBONDATA-137] Fixed detail limit query statistics issue (#904)

In case of detail query with limit it total query execution time in statistics is printing
negative values as wrong method is getting called

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

Branch: refs/heads/master
Commit: b4ae2eb73b6dbc6f25717bfeaa9c5f55fb471c21
Parents: d70a6e5
Author: Kumar Vishal <kumarvishal.1802@gmail.com>
Authored: Thu Aug 4 12:55:42 2016 +0530
Committer: Venkata Ramana G <g.ramana.v1@gmail.com>
Committed: Thu Aug 4 12:55:42 2016 +0530

----------------------------------------------------------------------
 .../src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/b4ae2eb7/integration/spark/src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala
----------------------------------------------------------------------
diff --git a/integration/spark/src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala
b/integration/spark/src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala
index 9eb680c..8a545e8 100644
--- a/integration/spark/src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala
+++ b/integration/spark/src/main/scala/org/carbondata/spark/rdd/CarbonQueryRDD.scala
@@ -232,7 +232,7 @@ class CarbonQueryRDD[V: ClassTag](
           if (null != queryModel.getStatisticsRecorder) {
             val queryStatistic = new QueryStatistic
             queryStatistic
-              .addStatistics("Total Time taken to execute the query in executor Side",
+              .addFixedTimeStatistic("Total Time taken to execute the query in executor Side",
                 System.currentTimeMillis - queryStartTime
               )
             queryModel.getStatisticsRecorder.recordStatistics(queryStatistic);
@@ -253,7 +253,7 @@ class CarbonQueryRDD[V: ClassTag](
           if (null != queryModel.getStatisticsRecorder) {
             val queryStatistic = new QueryStatistic
             queryStatistic
-              .addStatistics("Total Time taken to execute the query in executor Side",
+              .addFixedTimeStatistic("Total Time taken to execute the query in executor Side",
                 System.currentTimeMillis - queryStartTime
               )
             queryModel.getStatisticsRecorder.recordStatistics(queryStatistic);


Mime
View raw message