Spark如何将(键值列表)拆分成键值对

# 导入Spark相关库
from pyspark import SparkContext

# 创建SparkContext
sc = SparkContext("local", "KeyValuePairs")

# 创建键值列表
key_value_list = [("key1", [1, 2, 3]), ("key2", [4, 5, 6]), ("key3", [7, 8, 9])]

# 将键值列表拆分成键值对
key_value_pairs = sc.parallelize(key_value_list).flatMap(lambda x: [(x[0], value) for value in x[1]])

# 打印结果
print(key_value_pairs.collect())

# 停止SparkContext
sc.stop()

[('key1', 1), ('key1', 2), ('key1', 3), ('key2', 4), ('key2', 5), ('key2', 6), ('key3', 7), ('key3', 8), ('key3', 9)]