實(shí)例1

var text = sc.parallelize(Seq("a","b","c","a","b","b"))

text.filter(_.contains("a")).count

var wc = text.flatMap(line=>line.split("")).map(word=>(word,1)).reduceByKey((a,b)=>a+b)

wc.collect

val text = sc.textFile("/data/sofoware/unpacks/spark-1.6.2-bin-hadoop2.6/README.md")

text.filter(line=>line.contains("Apache Spark")).count