[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

dynamic tables in cassandra sink

Hi there,

I have a flink stream from kafka writing to Cassandra. We use monthly tables in Cassandra to avoid TTL and tombstones that come with it. Tables would be like table_05_2018, table_06_2018 and so on. How do I dynamically register this table name in the following snippet?

.setQuery("INSERT INTO table_05_2018(id, text) VALUES (?,?);")