有没有办法在PySpark中读取文本文件时控制分区数

我在PySpark中使用以下命令读取文本文件

rating_data_raw = sc.textFile("/.csv")

有没有办法指定RDD rating_data_raw应分成的分区数？我想指定大量的分区以实现更高的并发性.

正如其他用户所说,您可以在读取文件时设置将创建的最小分区数,方法是在textFile的可选参数中minPartitions进行设置.

rating_data_raw = sc.textFile("/.csv", minPartitions=128)

实现此目的的另一种方法是使用重新分区或合并,如果您需要减少可能使用的分区数coalesce,否则您可以使用repartition.

rating_data_raw = sc.textFile("/.csv").repartition(128)