Short description (≤350 chars): PySpark analytics pipeline: ingest orders/products/customers/returns, transform with broadcast joins and windowing, data quality ...
member_coverage member_id, plan_id, start_date, end_date, network_ind One row per member-plan-coverage period admin_events event_id, member_id, event_type, event_date, channel One row per admin event ...