Выполнить запрос к данным реального времени

Данные можно обрабатывать не только из систем хранения типа 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
• Функции агрегации данных