Understand the Data Ingestion modular pipeline
mainThe data_ingestion pipeline is a modular component designed to transform raw data into structured, typed, and aggregated domain-level tables.
Workflow Steps:
- Intermediate Level: Takes raw
companies,shuttles, andreviewsdata and creates typed Parquet mirrors at theintermediatelevel. - Aggregation: Aggregates
companiesdata to ensure a single row per company. - Primary Domain Level: Merges the three sources to create two specific
primarytables:prm_spine_table: Contains only relevant ID columns at the required grain. This table serves as the foundation for all subsequentfeatureandmodel_inputtables, ensuring they maintain the same row count and column alignment.prm_shuttle_company_reviews: Contains metrics intended for use as features or model inputs later in the pipeline.