You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@griffin.apache.org by li...@apache.org on 2018/04/26 08:12:36 UTC

[13/50] [abbrv] incubator-griffin git commit: comments in debug

comments in debug


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

Branch: refs/heads/griffin-0.2.0-incubating-rc4
Commit: 3d3b9f1038d08576bf2984dc9e97a172709f4223
Parents: 898da63
Author: Lionel Liu <bh...@163.com>
Authored: Tue Apr 10 12:58:23 2018 +0800
Committer: Lionel Liu <bh...@163.com>
Committed: Tue Apr 10 12:58:23 2018 +0800

----------------------------------------------------------------------
 .../apache/griffin/measure/process/engine/SparkSqlEngine.scala   | 4 ++--
 .../griffin/measure/rule/dsl/analyzer/CompletenessAnalyzer.scala | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3d3b9f10/measure/src/main/scala/org/apache/griffin/measure/process/engine/SparkSqlEngine.scala
----------------------------------------------------------------------
diff --git a/measure/src/main/scala/org/apache/griffin/measure/process/engine/SparkSqlEngine.scala b/measure/src/main/scala/org/apache/griffin/measure/process/engine/SparkSqlEngine.scala
index ce85e7a..438595b 100644
--- a/measure/src/main/scala/org/apache/griffin/measure/process/engine/SparkSqlEngine.scala
+++ b/measure/src/main/scala/org/apache/griffin/measure/process/engine/SparkSqlEngine.scala
@@ -47,8 +47,8 @@ case class SparkSqlEngine(sqlContext: SQLContext) extends SparkDqEngine {
             }
           } else sqlContext.sql(rule)
 
-          println(name)
-          rdf.show(30)
+//          println(name)
+//          rdf.show(3)
 
           if (rs.isGlobal) {
             if (rs.needCache) DataFrameCaches.cacheGlobalDataFrame(name, rdf)

http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3d3b9f10/measure/src/main/scala/org/apache/griffin/measure/rule/dsl/analyzer/CompletenessAnalyzer.scala
----------------------------------------------------------------------
diff --git a/measure/src/main/scala/org/apache/griffin/measure/rule/dsl/analyzer/CompletenessAnalyzer.scala b/measure/src/main/scala/org/apache/griffin/measure/rule/dsl/analyzer/CompletenessAnalyzer.scala
index 7df1a84..ad56e1a 100644
--- a/measure/src/main/scala/org/apache/griffin/measure/rule/dsl/analyzer/CompletenessAnalyzer.scala
+++ b/measure/src/main/scala/org/apache/griffin/measure/rule/dsl/analyzer/CompletenessAnalyzer.scala
@@ -40,7 +40,7 @@ case class CompletenessAnalyzer(expr: CompletenessClause, sourceName: String) ex
   }
 
   if (selectionPairs.isEmpty) {
-    throw new Exception(s"uniqueness analyzer error: empty selection")
+    throw new Exception(s"completeness analyzer error: empty selection")
   }
 
 }