timgent

val predictedOrdersChecks = ChecksSuite("orders",
  dualDsChecks = Map(
    DescribedDsPair(DescribedDs(orders, "orders"), DescribedDs(predictedOrders, "predictedOrders")) ->
      Seq(
        DualMetricCheck(CountDistinctValuesMetric(List("customerId")), CountDistinctValuesMetric(List("customerId")),
        "predicted orders present for every customer", MetricComparator.metricsAreEqual)
      )
  )
)