【文件属性】：
文件名称：cassandra-dataflow:用于 Cassndra 的 Google Dataflow 连接器
文件大小：10KB
文件格式：ZIP
更新时间：2021-06-02 19:01:27
Java
卡桑德拉连接器
非常粗糙的工作。
用法：
CassandraIO . Write . Unbound spec = CassandraIO . Write
.hosts( " localhost " )
.port( 9042 )
.keyspace( " paypoint " );
PTransform< PCollection> , PDone > > sink = spec . < Row> bind();
PCollection< Row> rows = ??? ;
row . appy(sink);
其中Row是使用 Datastax 持久性 API（类似 JPA 的注释）的某种类型类型。
去做
允许设置更多集群对象选项。
使用静态映射防止每个 JVM 过度创建集群/会话
Javadoc
允许阅读
可调批量大小
有很多工作要做。
【文件预览】：
cassandra-dataflow-master
----.gitignore(8B)
----cassandra-dataflow()
--------src()
----LICENSE.txt(11KB)
----README.md(631B)
----build.sbt(1KB)