SimpleSparkApp.scala

import org.apache.spark.{SparkContext, SparkConf}

object SimpleSparkApp extends App {
  
  override def main(args: Array[String]) = {

    val config: SparkConf = new SparkConf() 
    config.setMaster("local[4]")
    config.setAppName("MySimpleSparkApp")
    
    val sc = new SparkContext(config)
    
    val rows = Seq( Seq("item-1-1", "item-1-2"), Seq("item-1-1", "item-2-2"))
    val rdd = sc.parallelize(rows)
    
    println(rdd.count())
  }
}