现有2-1.txt文件,文件目录为D:\2-1.txt,部分文件内容如图所示。要求读取2-1.txt创建Pair RDD,并对相同key值进行归约,value值进行相加,输出最终结果。

您可以使用以下代码来实现您的需求：

from pyspark import SparkContext

# 创建SparkContext对象
sc = SparkContext("local", "PairRDD Example")

# 读取2-1.txt文件创建Pair RDD
lines = sc.textFile("D:\\2-1.txt")
pair_rdd = lines.map(lambda line: line.split(",")).map(lambda x: (x[0], int(x[1])))

# 对相同key值进行归约，value值进行相加
result_rdd = pair_rdd.reduceByKey(lambda x, y: x + y)

# 输出最终结果
result = result_rdd.collect()
for key, value in result:
    print(key, value)

请注意，您需要将文件路径`D:\\2-1.txt`更改为实际文件的路径。此代码将逐行读取文件并将每行拆分为键值对，然后使用`reduceByKey`函数对具有相同键的值进行归约和相加操作。最后，使用`collect`函数将结果收集到驱动程序并进行打印。

希望能对您有所帮助！