Value)为一个list
1.keys()
该函数返回键值对RDD中,所有键(key)组成的RDD
pyspark.RDD.keys
# the example of keys
print("rdd_test_keys...所有值(values)组成的RDD
pyspark.RDD.values
# the example of values
print("rdd_test_values\n", rdd_test.values...53.07, 46.93, 113.08])), (103.15, ('Jiangsu', [50.78, 49.22, 103.15])) ]
4.mapValues()
对原始键值对RDD的每个元素中的值...Beijing', 204), ('Shanghai', 207), ('Guangdong', 213), ('Jiangsu', 203)]
5.flatMapValues()
对原始键值对RDD的每个元素中的值...numPartitions的值是要执行归约任务数量,同时还会影响其他行动操作所产生文件的数量;
而处一般可以指定接收两个输入的 匿名函数。