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