PL-001 · Finance
Billing Ledger Ingest
Incremental change capture from a mock order-entry schema into a partitioned billing fact table, with currency normalisation and late-arriving-record handling.
- 1
Extract CDC window extract
SCN-bounded read against the simulated source with watermark checkpointing.
~34s average
- 2
Normalise & enrich transform
Currency conversion, surrogate key lookup, dedupe on (order_id, revision).
~61s average
- 3
Constraint validation validate
Row count reconciliation, referential checks, null-rate thresholds.
~18s average
- 4
Partition-wise load load
Direct-path insert into the current monthly partition, then index rebuild.
~47s average
| Run | Started (UTC) | Duration | Rows in | Rows out | Reject % | SLA | Status |
|---|---|---|---|---|---|---|---|
| R-8841 | 2026-08-13 16:45:00 | 158s | 184,320 | 184,180 | 0.08% | Met | healthy |
| R-8840 | 2026-08-13 16:30:00 | 171s | 179,004 | 178,901 | 0.06% | Met | healthy |
| R-8839 | 2026-08-13 16:15:00 | 402s | 201,553 | 199,870 | 0.84% | Met | degraded |