我是Apache·Flink的新手。我正在使用pojosink将数据加载到cassandra中。现在，我正在@table annotation的帮助下指定表和键空间的名称。现在，我想在运行时动态传递表名和键空间名，以便将数据加载到用户指定的表中。有没有办法做到这一点？
uqxowvwt1#
@表是一个cql注解，它定义了这个类实体Map到哪个表。afaik，目前没有办法使它在运行时动态Map到任何表，因为如果没有指定类名，它将推断类名，即。
@Table public class MyTable {...}
推断表“mytable”
@Table(table = "another_table") public class AnotherTable
推断表“另一个表”
1条答案
按热度按时间uqxowvwt1#
@表是一个cql注解，它定义了这个类实体Map到哪个表。afaik，目前没有办法使它在运行时动态Map到任何表，因为如果没有指定类名，它将推断类名，即。
推断表“mytable”
推断表“另一个表”