Skip to content

Latest commit

 

History

History
11 lines (6 loc) · 373 Bytes

File metadata and controls

11 lines (6 loc) · 373 Bytes

Microbatch Hourly Deduped Tutorial

Deduping hourly data can be challenging. The duplicates can occur across hours as well.

This design is how you can reduce the daily data latency dramatically by deduping your data both hourly and across hours using GROUP BY and FULL OUTER JOIN

An example DAG in Airflow is here

Diagram