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 <[email protected]> Authored: Tue Apr 10 12:58:23 2018 +0800 Committer: Lionel Liu <[email protected]> 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") } }
