【文件属性】：
文件名称：scalaflow:适用于Google的Cloud Dataflow SDK的Fluent Scala DSL
文件大小：14KB
文件格式：ZIP
更新时间：2021-05-18 12:30:15
Scala
Scalaflow
Scalaflow是用于Google的Cloud Dataflow的Java SDK的Scala DSL。
数据流是一项很酷的服务，但是如果我们可以使用流利的样式在Scala中编写数据管道和分布式数据转换，它甚至会更酷：
object ScalaStyleWordCount extends App {
// pipeline definition
val options = PipelineOptionsFactory
.fromArgs(args)
.withValidation()
.as( classOf [ WordCountOptions ])
val job = new DataflowJob (options)
// input
val input = job.text(options.getInput(
【文件预览】：
scalaflow-master
----.gitignore(154B)
----project()
--------Build.scala(922B)
----src()
--------main()
--------test()
----logging.properties(102B)
----README.md(2KB)