Создать таблицу SQL из DataStream в программе Java / Scala и запросить ее из CLI клиента SQL - Apache Flink

Question

Возможно ли взаимодействие с таблицей с помощью клиентского интерфейса командной строки Flink SQL, где эта таблица была создана в программе Scala / Java, работающей в кластере?

Answer 1

Нет, это невозможно.

Вы можете поместить DataStream программы Scala / Java в тему в очереди сообщений или журнале событий, например Apache Kafka или Apache Pulsar, и зарегистрировать тему в виде таблицы в клиенте CLI.

После регистрации таблицы ее можно запросить с помощью SQL в клиенте.