Выполнить запрос к данным реального времени
Данные можно обрабатывать не только из систем хранения типа Yandex Object Storage, но и из шин потоков данных типа Yandex Data Streams.
В примере ниже показано, как нарезать входные данные на одноминутные интервалы, внутри каждого интервала посчитать количество событий и сумму:
SELECT
HOP_END() AS time,
COUNT(*) AS ride_count,
SUM(total_amount) AS total_amount
FROM
(
SELECT
*
FROM
bindings.`tutorial-streaming`
LIMIT 10
)
GROUP BY
HOP(Just(CAST(tpep_pickup_datetime AS Timestamp)), "PT1M", "PT1M", "PT1M");
См. также
- Оператор SELECT
- Оператор GROUP BY
- Оператор HOP
- Функции агрегации данных