文件名称:scala-dataflow-dsl:用于数据流的 scala dsl
文件大小:7KB
文件格式:ZIP
更新时间:2024-07-23 16:40:22
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)