debug combine files

gistfile1.scala

package com.chandler

import com.twitter.scalding._
import com.twitter.scalding.commons.source._

case class TestLzoSource(p : String) extends FixedPathSource(p) with LzoText

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