blob: 0de6ae0ee67419c4a3836a5347ac784f59ff5002 (
plain)
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")))
}
|