scala dataflow dslScala数据流接口

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

  }

}