E-commerce Batch & Streaming Lakehouse
A reproducible warehouse that computes the same e-commerce metrics through two paths: MySQL + Doris for batch layers, and Kafka + Flink SQL for a real-time DWD → DWS → ADS chain. A Statement Set materializes Paimon layers and Doris ADS outputs in parallel before field-level reconciliation.
- ProblemBatch reports and live dashboards can diverge when metric definitions, windows, or source paths differ.
- DesignDoris implements physical batch layers; Flink SQL carries shared definitions through temporary views and writes Paimon plus Doris outputs in one Statement Set.
- ResultAll core metrics and average order value reconcile across fixed 1-, 7-, and 30-day windows.