Repository: incubator-griffin Updated Branches: refs/heads/master 9a6dc4ba7 -> 3a5746ef1
modify distinctness trans logic Author: Lionel Liu <[email protected]> Closes #217 from bhlx3lyx7/tmst. Project: http://git-wip-us.apache.org/repos/asf/incubator-griffin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-griffin/commit/3a5746ef Tree: http://git-wip-us.apache.org/repos/asf/incubator-griffin/tree/3a5746ef Diff: http://git-wip-us.apache.org/repos/asf/incubator-griffin/diff/3a5746ef Branch: refs/heads/master Commit: 3a5746ef116c0f1ba7b27fad6b60cc2f88f80741 Parents: 9a6dc4b Author: Lionel Liu <[email protected]> Authored: Wed Feb 7 18:46:14 2018 +0800 Committer: Lionel Liu <[email protected]> Committed: Wed Feb 7 18:46:14 2018 +0800 ---------------------------------------------------------------------- .../measure/rule/trans/DistinctnessRulePlanTrans.scala | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3a5746ef/measure/src/main/scala/org/apache/griffin/measure/rule/trans/DistinctnessRulePlanTrans.scala ---------------------------------------------------------------------- diff --git a/measure/src/main/scala/org/apache/griffin/measure/rule/trans/DistinctnessRulePlanTrans.scala b/measure/src/main/scala/org/apache/griffin/measure/rule/trans/DistinctnessRulePlanTrans.scala index f45911f..5e3819c 100644 --- a/measure/src/main/scala/org/apache/griffin/measure/rule/trans/DistinctnessRulePlanTrans.scala +++ b/measure/src/main/scala/org/apache/griffin/measure/rule/trans/DistinctnessRulePlanTrans.scala @@ -61,7 +61,12 @@ case class DistinctnessRulePlanTrans(dataSourceNames: Seq[String], val ct = timeInfo.calcTime - val beginTmstOpt = dsTimeRanges.get(sourceName).flatMap(_.beginTmstOpt) +// val beginTmstOpt = dsTimeRanges.get(sourceName).flatMap(_.beginTmstOpt) +// val beginTmst = beginTmstOpt match { +// case Some(t) => t +// case _ => throw new Exception(s"empty begin tmst from ${sourceName}") +// } + val beginTmstOpt = dsTimeRanges.get(sourceName).map(_.end) val beginTmst = beginTmstOpt match { case Some(t) => t case _ => throw new Exception(s"empty begin tmst from ${sourceName}")
