Cassandra Pojo下沉的动态桌子名称



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

@Table是一个CQL注释,定义了该类实体映射到哪个表。afaik,目前无法在运行时动态映射到任何表格,因为如果未指定名称,即。

@Table
public class MyTable {...}

添加表'mytable'

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

注入表'另一个_table'

相关内容

  • 没有找到相关文章

最新更新