WordCount.scala

class WordCountJob(args : Args) extends Job(args) {
  TextLine( args("input") )
    .flatMap('line -> 'word) { line : String => tokenize(line) }
    .groupBy('word) { _.size }
    .write( Tsv( args("output") ) )
}  
                  BECOMES
                  
 class WordCountJob(args: Args) extends Job(args) {
   val lines : TypedPipe[String] = TextLine(args("input"))
   val words = lines.flatMap('line -> 'word) { line => line.split("\\s+")
   val groupedWord = words.groupBy(identity)
   val countedWords = groupedWord.size
   countedWords.write(TypedTsv[(String,Long)](args("output")))
     
 }