import com.nicta.scoobi.Scoobi._

object WordCount extends ScoobiApp {
  def run() {

    val data = fromTextFile("giant-input.txt")

    val executionGraph: DObject[Int] = data.map(_.toLong).distinct.size

    // run the job:
    val result: Int = persist(executionGraph)


    println("There is a total of: " + result + " distinct numbers")
  }
}