04 · Architecture
Explore the complete Uber data flow from marketplace producers to live decisions and trusted historical products.
Architecture decision
Flink · seconds
Continuously update live state
Rolling supply cells, surge inputs, ETA features, and current trip sessions feed operational services.
Spark + Airflow · scheduled
Reconcile historical truth
Late and duplicate events are corrected into auditable trip, shift, and settlement facts.