Как автоматически зарегистрировать TableSink в клиенте Flink SQL? - PullRequest
0 голосов
/ 30 марта 2020

У меня есть реализация custom TableSink, которую я хочу использовать в SQL Client. Я видел --jar вариант, но я не думаю, что он решает мою проблему. То, чего я пытаюсь добиться, - это запустить некоторый конфигурационный код, который бы настраивал среду: например, он создавал бы кучу приемников и источников и регистрировал их на TableEnvironment (т.е. используя tableEnv.createTemporaryTable("...")), и только тогда я хотел бы запустить SQL запросов, предоставленных пользователем. Есть ли у вас какие-либо идеи, если это вообще возможно в текущей версии SQL Client?

...