Я намерен получить список всех столбцов, используемых в текущем SQL из всех исходных таблиц. Например:
Table X(int a, String b, String e)
Table Y(String c, String d)
SELECT
X.a
Y.c
from X
join Y on X.b = Y.c
...
;
Тогда ожидаемый результат должен быть {"X": ["a", "b"], "Y": ["c"]} , X.e и Y.d не должны появляться в результате, поскольку они не использовались в предыдущем SQL.
Есть идеи, как этого добиться в Flink SQL? Благодаря.