cassandrapojo Sink Flink中的java动态表名


0

我是 Apache· Flink的新手。我使用Pojo Sink将数据加载到Cassandra中。现在,我在@table注释的帮助下指定表和 key空间名称。

1 答案


0

@Table是一个CQL注释,它定义这个类实体 map到哪个表。AFAIK,目前还没有办法使它在运行时动态 map到任何表,因为如果不指定名称,它将推断类名,即。

@Table
public class MyTable {...}

推断表“mytable”

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

推断表“另一张表”


我来回答

写文章

提问题

面试题