闲来无事，研究一下Spark Rdd的处理过程。 以一个简单的例子看看： val textRDD = sc.textFile("/home/ubuntu/people.txt") val filterRDD = text…