如何在google-dataflow中读取cassandra

Question

我有一个用例，我想从Cassandra表中读取所有内容并创建一个PCollection。有没有我可以使用的库，或者我应该只使用Cassandra驱动程序和从头开始的代码？

Answer 1

据我所知，目前还没有针对数据流的Cassandra源代码(尽管有一个sink)。有关从MySQL中读取的信息，请咨询this question --连接到Cassandra的注意事项非常相似。BEAM-244也是相关的。