A system must ingest clickstream events continuously, transform them, and make them queryable for near-real-time analytics. Which pipeline is the canonical Google Cloud design?