Search code examples
cassandraapache-flinkflink-streaming

Dynamic table name or query for Cassandra connector / Dynamic sink of Flink job

My Flink job needs to write to different Cassandra tables for different time. For this scenario, either dynamic table name or dynamic query for Cassandra connector, or dynamic sink for the Flink job works for me.

There is a similar question 3 years ago, and the answer is no. (Dynamic Table name in Cassandra Pojo Sink Flink) I am wondering if there is any update.

Thanks a lot!

Solution

  • Nvm, I implemented my own Cassandra sink, which generates different query when sending the data to Cassandra. I referred to the existing CassandraRowSink in Flink. It works for this use case.