Casos de uso en tiempo real con Cloud Pub/Sub y Dataflow

Consulta:

SELECT
    TUMBLE_START('INTEVARL 1 MINUTE') as period_start,
    SUM(passenger_count) AS pickup_count
FROM pubsub.topic.`pubsub-public-data`.`taxirides-realtime`
WHERE
    ride_status = "pickup"
GROUP BY
    TUMBLE(event_timestamp, 'INTERVAL 1 MINUTE')

antes de ver la parte practica de esta clase mira esto:
https://www.youtube.com/watch?v=f5DOsB7Nlw0&list=PLIivdWyY5sqKwVLe4BLJ-vlh9r9zCdOse&index=3

SELECT
  TUMBLE_START('INTERVAL 1 MINUTE') as period_start,
  SUM(passenger_count) AS pickup_count
FROM pubsub.topic.`pubsub-public-data`.`taxirides-realtime`
WHERE
  ride_status = "pickup"
GROUP BY
  TUMBLE(event_timestamp,'INTERVAL 1 MINUTE')

Falta incluir el query

Para ejemplos practivos utilicé datos que muestran en la busqueda, pero se debió mostrar desde donde se buscó el servicio de pubsub porque parece que actualmente ya no está almenos no bajo la misma ruta

falta la sentencia para poder seguir la clase mejor

es increible apicla algo que no explica como lo obtuvo, yo no estoy pudiendo crear el job de ninguna forma