scalaflow:适用于Google的Cloud Dataflow SDK的Fluent Scala DSL

时间:2024-06-07 06:16:55
【文件属性】:

文件名称: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)

网友评论