A retail company is building an analytics platform using BigQuery as the data warehouse. The company wants to analyze real-time sales transactions from its point-of-sale (POS) systems and daily inventory updates from its suppliers. The company wants to use a single data ingestion framework to handle both real-time and batch processing efficiently. Which solution should the company use?