Flink Таблица SQL Api

Я хочу знать, можем ли мы написать запрос, используя две таблицы (объединение) в Flink Table и SQL API.

Я новичок в flik, я хочу создать две таблицы из двух разных наборов данных и запросить их и создать другой набор данных.

мой запрос будет похож select... from table1, table 2... так что мы можем написать как этот запрос, который запрашивает две таблицы или более?

Спасибо

Источник

1 ответ

Решение

Табличный API Flink поддерживает операции соединения (полное, левое, правое, внутреннее объединение) в пакетных таблицах (например, созданных из DataSet).

SELECT c, g FROM Table3, Table5 WHERE b = e

Для потоковых таблиц (например, созданных из DataStream), Flink пока не поддерживает операции объединения. Но сообщество Flink активно работает над тем, чтобы добавить их в ближайшее время.

Источник
Другие вопросы по тегам