akka streams in practice java8:使用Java 8的Akka Streams将数据从CSV文件导入到Cassandra 源码

实践中的Akka流 这是一个示例Akka Streams项目,该项目使用该库将大量Gzip CSV文件中的数据导入到Cassandra表中。 CSV文件包含某种读数,即(id, value)对,其中每个id具有两个关联的value s,并且给定id的记录出现在文件的后续行中。 任何value s有时可能都是无效数字。 例: 93500;0.5287942176336127 93500;0.3404326895942348 961989;invalid_value 961989;0.27452559752437566 136308;0.07525660747531115 136308;0.6