执行了多少次transformation操作,RDD都不会真正执行运算(记录lineage),只有当action操作被执行时,运算才会触发。...1)分区列表:通过分区列表可以找到一个RDD中包含的所有分区及其所在地址。
2)计算每个分片的函数:通过函数可以对每个数据块进行RDD需要进行的用户自定义函数运算。...() 各元素在RDD中出现的次数 rdd.countByValue() {1,1}, {2, 1}, {3,2}
take(n) 从RDD中返回n个元素 rdd.take(2) {1,2}
top(n)...从RDD中返回前n个元素 rdd.top(3) {3,3,2}
foreach(func) 对RDD中的每个元素使用给定的函数 rdd.foreach(print) 1,2,3,3
2.2 行动操作...rdd.countByValue() {1,1}, {2, 1}, {3,2}
take(n) 从RDD中返回n个元素 rdd.take(2) {1,2}
top(n) 从RDD中返回前n个元素 rdd.top