gpt4 book ai didi

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

转载 作者:搜寻专家 更新时间:2023-11-01 03:47:35 33 4
gpt4 key购买 nike

我是 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 Pojo Sink Flink 中的动态表名,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41183039/

33 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com