gistfile1.scala

import org.apache.spark.SparkContext
import org.apache.spark.SparkContext._ //implicit conversion用 このソースでは使っていないけど書いておくといい
import org.apache.spark.SparkConf

object SampleApp {
  def main(args: Array[String]) {
    val srcFileName = "/work/data/something.gz"

    val conf = new SparkConf().setAppName("SampleApp")
    val sc = new SparkContext(conf)
    val src = sc.textFile(srcFileName).cache()
    val lines = src.count()

    println("Lines %,d".format(lines))
  }
}