我是Apache Flink的新手。我正在使用Pojo ang将数据加载到Cassandra中。现在,我在 @Table 注释的帮助下指定表和键空间名称。
现在,我想在运行时间动态传递表名和键空间名称,以便可以将数据加载到用户指定的表中。有什么办法可以实现这一目标?
@Table是一个CQL注释,定义了该类实体映射到哪个表。afaik,目前无法在运行时动态映射到任何表格,因为如果未指定名称,即。
@Table
public class MyTable {...}
添加表'mytable'
@Table(table = "another_table")
public class AnotherTable
注入表'另一个_table'