CascadeJobExample.scala

class Yada(args:Args) extends CascadeJob(args) {

  val out = Tsv(args("output"),'a)

  override def jobs: Seq[Job] = List(new First(args), new Second(args));

  class First(args:Args) extends Job(args) {
    val  s = IterableSource(List[Int](1,2,3,4,5,6,7,6,5,4,3,2), 'a)
      .write(out)
  }

  class Second(args:Args) extends Job(args) {
    val x = out.read
      .map('a,'a) { x:String =>  "x.." + x}
      .write(Tsv(args("output2")))
  }

  override def validate {
    jobs.foreach { _.validate }
  }
}