文件名称:scalaflow:适用于Google的Cloud Dataflow SDK的Fluent Scala DSL
文件大小:14KB
文件格式:ZIP
更新时间:2024-06-07 06:16:55
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)