Cassandra 连接器的动态表名或查询/Flink 作业的动态接收器答案

【问题标题】：Dynamic table name or query for Cassandra connector / Dynamic sink of Flink jobCassandra 连接器的动态表名或查询/Flink 作业的动态接收器
【发布时间】：2020-02-29 23:28:02
【问题描述】：

我的 Flink 工作需要在不同的时间写入不同的 Cassandra 表。对于这种情况，Cassandra 连接器的动态表名或动态查询，或 Flink 作业的动态接收器都适合我。

3年前有一个类似的问题，答案是否定的。 (Dynamic Table name in Cassandra Pojo Sink Flink) 不知有没有更新。

非常感谢！

【问题讨论】：

在 flink jira 任务中没有找到任何使用“动态表名 Cassandra”“动态查询 Cassandra”等关键字的相关票证...(issues.apache.org/jira/browse/…)

标签： cassandra apache-flink flink-streaming

【解决方案1】：

Nvm，我实现了自己的 Cassandra 接收器，它在将数据发送到 Cassandra 时会生成不同的查询。我提到了 Flink 中现有的 CassandraRowSink。它适用于这个用例。

【讨论】：