java - Cassandra Pojo Sink Flink 中的动态表名

Question

我是 Apache Flink 的新手。我正在使用 Pojo Sink 将数据加载到 Cassandra 中。现在，我在 @Table 注释的帮助下指定表和键空间名称。
现在，我想在运行时动态传递表名和键空间名称，以便我可以将数据加载到用户指定的表中。有什么办法可以实现吗？

Answer 1

@Table 是一个 CQL 注解，定义了这个类实体映射到哪个表。 AFAIK，目前没有办法让它在运行时动态映射到任何表，因为如果没有指定名称，它会推断出类名，即

@Table
public class MyTable {...}

推断出一个表'mytable'

@Table(table = "another_table")
public class AnotherTable 

推断表'another_table'