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

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

解决方法:

@Table是一个CQL注释,用于定义此类实体映射到的表. AFAIK,目前无法在运行时将其动态映射到任何表,因为如果未指定名称,它将推断出类名,即

@Table
public class MyTable {...}

推断表’mytable’

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

推断表’another_table’

标签：java,cassandra,apache-flink
来源： https://codeday.me/bug/20190710/1429016.html