Самый эффективный способ в Flink выполнить поиск sql потока данных

Question

Учитывая поток данных от Kafka, есть ли встроенный способ или какой самый эффективный способ выполнить поиск SQL.

Например, если объект потока подключен к таблице sql и соединен с потоком данных Kafka. Учитывая таблицу sql, которую можно обновлять по отдельности c,

Answer 1

Кажется очевидным ответом является использование SQL API Флинка, который задокументирован здесь .

Также есть некоторые Flink SQL обучение , которые включает установку на основе docker, где вы можете использовать SQL клиент Flink для выполнения интерактивных SQL запросов к потоку данных Kafka.