Cassandra Pojo Sink Flink 中的动态表名称

【问题标题】：Dynamic Table name in Cassandra Pojo Sink FlinkCassandra Pojo Sink Flink 中的动态表名称
【发布时间】：2016-12-16 11:06:34
【问题描述】：

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

【问题讨论】：

【解决方案1】：

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

@Table
public class MyTable {...}

推断一个表'mytable'

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

推断表'another_table'

【讨论】：