scald-mvp/src/main/scala/example/WordCount.scala


1
2
3
4
5
6
7
8
9
10
11
12


package example

import com.twitter.scalding._

class WordCount(args : Args) extends Job(args) {
  TypedPipe.from(TextLine(args("input")))
    .flatMap { line => line.split("""\s+""") }
    .groupBy { word => word }
    .size
    .write(TypedTsv(args("output")))
}