| withRetry(int, Function0) |   | 29% | | 10% | 5 | 6 | 2 | 5 | 0 | 1 |
| warnMissedReconciliation(Row) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| collectFailures(String, SparkSession) | | 93% | | 50% | 2 | 3 | 0 | 21 | 0 | 1 |
| $anonfun$collectLateEvents$1(ReconcileCollector, Row) | | 87% | | 33% | 6 | 7 | 1 | 11 | 0 | 1 |
| $anonfun$fetchLatestRevision$5(Tuple5, Tuple5) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| buildSourceTag(String, Option) | | 76% | | 66% | 2 | 4 | 0 | 6 | 0 | 1 |
| $anonfun$collectInconsistencies$1(ReconcileCollector, Row) | | 90% | | 33% | 3 | 4 | 1 | 11 | 0 | 1 |
| $anonfun$fetchLatestRevision$12(ReconcileCollector, Tuple2) | | 92% | | 75% | 2 | 5 | 0 | 6 | 0 | 1 |
| $anonfun$collectFailures$4(ReconcileCollector, Tuple5) | | 90% | | 50% | 1 | 2 | 0 | 10 | 0 | 1 |
| $anonfun$fetchLatestRevision$11(Tuple2) | | 82% | | 50% | 1 | 2 | 0 | 2 | 0 | 1 |
| $anonfun$fetchLatestRevision$2(ReconcileCollector, Function1, Tuple2) | | 78% | | 50% | 1 | 2 | 0 | 4 | 0 | 1 |
| $anonfun$fetchLatestRevision$8(Map, Tuple2) | | 77% | | 50% | 1 | 2 | 0 | 2 | 0 | 1 |
| $anonfun$collectFailures$2(Tuple5) | | 68% | | 50% | 1 | 2 | 0 | 2 | 0 | 1 |
| $anonfun$collectFailures$3(Tuple5) | | 68% | | 50% | 1 | 2 | 0 | 2 | 0 | 1 |
| $anonfun$fetchLatestRevision$10(Tuple2) | | 64% | | 50% | 1 | 2 | 0 | 2 | 0 | 1 |
| $lessinit$greater$default$8() | | 0% | | n/a | 1 | 1 | 0 | 0 | 1 | 1 |
| $lessinit$greater$default$7() | | 0% | | n/a | 1 | 1 | 0 | 0 | 1 | 1 |
| $lessinit$greater$default$6() | | 0% | | n/a | 1 | 1 | 0 | 0 | 1 | 1 |
| MW_CALL_RETRY_WAIT_MS() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| $anonfun$collectLateEvents$2() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| $anonfun$fetchLatestRevision$9() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| collectInconsistencies(String, SparkSession) | | 100% | | n/a | 0 | 1 | 0 | 22 | 0 | 1 |
| collectLateEvents(String, SparkSession) | | 100% | | n/a | 0 | 1 | 0 | 19 | 0 | 1 |
| ReconcileCollector(String, String, String, Function1, Function1, Function0, Function0, Function0) | | 100% | | n/a | 0 | 1 | 0 | 23 | 0 | 1 |
| $anonfun$fetchLatestRevision$6(ReconcileCollector, Function1, Map) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
| rowToEventMeta(Row) | | 100% | | n/a | 0 | 1 | 0 | 6 | 0 | 1 |
| $anonfun$collectFailures$1(ReconcileCollector, Row) | | 100% | | n/a | 0 | 1 | 0 | 6 | 0 | 1 |
| $anonfun$fetchLatestRevision$7(Function1, Map) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| fetchLatestRevision(List, Function1) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| rowToEventInfo(Row) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| $anonfun$fetchLatestRevision$4(List) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| $anonfun$fetchLatestRevision$1(Tuple5) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| $anonfun$fetchLatestRevision$3(Tuple5) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| $anonfun$collectFailures$2$adapted(Tuple5) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| $anonfun$collectFailures$3$adapted(Tuple5) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| $anonfun$fetchLatestRevision$10$adapted(Tuple2) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| logger() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| schema() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lateEventActionMap() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| inconsistenciesActionMap() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| requireEmitterId() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| MW_CALL_RETRIES() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| withRetry$default$1() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| $anonfun$rowToEventMeta$1(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| $anonfun$collectInconsistencies$2() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |