fix ratio in constraint_message

awslabs · Dec 6, 2023 · 149d84b · 149d84b
1 parent 1fc09e1
commit 149d84b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/com/amazon/deequ/comparison/ReferentialIntegrity.scala b/src/main/scala/com/amazon/deequ/comparison/ReferentialIntegrity.scala
@@ -60,7 +60,7 @@ object ReferentialIntegrity extends ComparisonBase {
       val referenceSparkCols = reference.select(referenceColumns.map(col): _*)
       val mismatchCount = primarySparkCols.except(referenceSparkCols).count()
 
-      val ratio = if (mismatchCount == 0) 1.0 else (primaryCount - mismatchCount).toDouble / primaryCount
+      val ratio = mismatchCount.toDouble / primaryCount
 
       if (assertion(ratio)) {
         ComparisonSucceeded()