aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--scald-mvp/src/main/scala/example/WordCount.scala13
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 }