Wordcount in the scalding DSL for Cascading

wordcount.scala

package com.twitter.scalding

class WordCount(args : Args) extends Job(args) {
  TextLine( args("input") ).read.
    flatMap('line -> 'word) { line : String => line.split("\\s+") }.
    groupBy('word) { _.size }.
    write( Tsv( args("output") ) )
}