Блог

Я создаю своего рода оболочку вокруг Flink SQL. Я создаю задание с помощью набора пользовательских инструкций SQL StreamTableEnvironment.sqlUpdate . Некоторые INSERT из них s, некоторые CREATE s. Я также делаю некоторые sqlQuery s.

Перед вызовом я StreamExecutionEnvironment.execute хотел бы перечислить все источники и приемники, созданные пользователем.

Есть ли простой / официальный способ сделать это, или мне нужно продолжить изучение StreamExecutionEnvironment.getStreamGraph().getJobGraph().getVerticesSortedTopologicallyFromSources() ?

С наилучшими пожеланиями

РЕДАКТИРОВАТЬ: мне нужны имена таблиц и связанные схемы.

Неважно, вы можете запрашивать таблицы в StreamTableEnvironment with StreamTableEnvironment.listTables() , а затем выполнять StreamTableEnvironment.from(tableName).getSchema()