在pyspark中创建rdd的rdd

from pyspark import SparkContext

# 创建SparkContext对象
sc = SparkContext()

# 从本地文件系统中加载文本文件创建RDD
rdd = sc.textFile("file:///path/to/file.txt")

# 从Hadoop文件系统中加载文本文件创建RDD
rdd = sc.textFile("hdfs://namenode:8020/path/to/file.txt")

from pyspark import SparkContext

# 创建SparkContext对象
sc = SparkContext()

# 创建Python列表
data = [1, 2, 3, 4, 5]

# 将Python列表转换为RDD
rdd = sc.parallelize(data)

from pyspark import SparkContext

# 创建SparkContext对象
sc = SparkContext()

# 创建原始RDD
data = [1, 2, 3, 4, 5]
rdd = sc.parallelize(data)

# 对RDD中的每个元素应用一个函数，生成新的RDD
new_rdd = rdd.map(lambda x: x * 2)