Список всех источников и приемников в задании Flink SQL

Question

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

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

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

С уважением

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

Answer 1

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