diff options
Diffstat (limited to 'scald-mvp')
| -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 } | 
