Flink 作业的 Cassandra 连接器/动态接收器的动态 table 名称或查询
Dynamic table name or query for Cassandra connector / Dynamic sink of Flink job
我的 Flink 作业需要在不同的时间写入不同的 Cassandra table。对于这种情况，Cassandra 连接器的动态 table 名称或动态查询，或 Flink 作业的动态接收器都适合我。
3年前有一个类似的问题，答案是否定的。 (Dynamic Table name in Cassandra Pojo Sink Flink)不知道有没有更新
非常感谢！
Nvm，我实现了自己的 Cassandra 接收器，它在将数据发送到 Cassandra 时生成不同的查询。我参考了 Flink 中已有的 CassandraRowSink。它适用于此用例。
我的 Flink 作业需要在不同的时间写入不同的 Cassandra table。对于这种情况，Cassandra 连接器的动态 table 名称或动态查询，或 Flink 作业的动态接收器都适合我。
3年前有一个类似的问题，答案是否定的。 (Dynamic Table name in Cassandra Pojo Sink Flink)不知道有没有更新
非常感谢！
Nvm，我实现了自己的 Cassandra 接收器，它在将数据发送到 Cassandra 时生成不同的查询。我参考了 Flink 中已有的 CassandraRowSink。它适用于此用例。