Потоковое чтение данных из топика

Можно выполнять чтение данных из топика обычным SELECT без создания потокового запроса. Для этого необходимо указать STREAMING = "TRUE" в блоке WITH и задать ограничение на количество выходных строк через LIMIT, иначе запрос не завершится.

Важно

Этот способ предназначен только для отладки и проверки данных в топике. Для production процессов создавайте потоковые запросы через CREATE STREAMING QUERY.

Примечание

В примерах:

  • ext_source — заранее созданный external data source;
  • input_topic — локальный или внешний топик.

Подробнее — локальные и внешние топики.

Пример

SELECT
    Data
FROM
    ext_source.input_topic -- или локальный топик input_topic
WITH (
    FORMAT = raw,
    SCHEMA = (
        Data String
    ),
    STREAMING = "TRUE"
)
LIMIT 1

См. также

Предыдущая
LIMIT OFFSET
Следующая
SHOW CREATE