在我滚烫的map reduce代码中，我想注销正在发生的某些步骤，以便在出现问题时调试map reduce作业。
我如何才能添加日志到我的烫伤工作？
例如

import com.twitter.scalding._
class WordCountJob(args: Args) extends Job(args) {
   //LOG: Starting job at time blah..
   TextLine( args("input") )
   .read
   .flatMap('line -> 'word) {
      line: String =>
      line.trim.toLowerCase.split("\\W+") 
   }
   .groupBy('word) { group => group.size('count) }
}
.write(Tsv(args("output")))
//LOG - ending job at time...
}