diff options
-rw-r--r-- | scald-mvp/src/main/scala/example/WordCount.scala | 13 |
1 files changed, 1 insertions, 12 deletions
diff --git a/scald-mvp/src/main/scala/example/WordCount.scala b/scald-mvp/src/main/scala/example/WordCount.scala index f7230c1..0de6ae0 100644 --- a/scald-mvp/src/main/scala/example/WordCount.scala +++ b/scald-mvp/src/main/scala/example/WordCount.scala @@ -3,18 +3,7 @@ package example import com.twitter.scalding._ -object WordCountJob { - - def main(args: Array[String]) { - (new WordCountJob(Args(List("--local", "", "--input", "dummy.txt", "--output", "dummy-out.txt")))).run - - import io.Source - for (line <- Source.fromFile("dummy-out.txt").getLines()) - println(line) - } -} - -class WordCountJob(args : Args) extends Job(args) { +class WordCount(args : Args) extends Job(args) { TypedPipe.from(TextLine(args("input"))) .flatMap { line => line.split("""\s+""") } .groupBy { word => word } |