Your organization wants to monitor sensor data from IoT devices in real time. The data must be ingested, transformed, and analyzed with minimal latency. The solution should support out-of-order events, scale automatically with data volume, and integrate easily with BigQuery for downstream analysis. Which Google Cloud service is best suited for handling this streaming data pipeline?