Мое задание Flink требует записи в разные таблицы Cassandra за разное время. Для этого сценария у меня работает либо динамическое c имя таблицы, либо динамический c запрос для коннектора Cassandra, либо динамический c приемник для задания Flink.
Есть похожий вопрос 3 года go, и ответ - нет. ( Dynami c Имя таблицы в Cassandra Pojo Sink Flink ) Мне интересно, есть ли обновление.
Большое спасибо!
Nvm, я реализовал свой собственный приемник Cassandra, который генерирует другой запрос при отправке данных в Cassandra. Я сослался на существующую CassandraRowSink во Flink. Это работает для этого варианта использования.