文件名称：cassandra-dataflow:用于 Cassndra 的 Google Dataflow 连接器
文件大小：10KB
文件格式：ZIP
更新时间：2024-06-22 12:48:07
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)