【文件属性】：
文件名称：scala-dataflow-dsl:用于数据流的 scala dsl
文件大小：7KB
文件格式：ZIP
更新时间：2021-07-03 22:53:42
Scala
Scala-数据流-dsl
数据流的 Scala 接口
该库允许您通过实现 Job 类，以原生 Scala 集合的方式编写数据流作业。 例如，我们可以通过运行以下作业类来计算字符串列表中的单词：
class LiterallyCountStuff extends Job {
override def createPipeline() = {
val inputdata: RichPCollection[String] = Create.of(List("stuff", "more stuff"))
val splitLowerCase: RichPCollection[String] = inputdata.flatMap(_.split("\\s+")).map(_
.toLowerCase)
val allCounts = splitLow
【文件预览】：
scala-dataflow-dsl-master
----src()
--------test()
--------main()
----README.md(692B)
----pom.xml(6KB)
----.gitignore(199B)