如何查看rdd的分区数

可以使用getNumPartitions()方法来查看RDD的分区数。具体的操作步骤如下：

首先，创建一个SparkSession对象（如果是在spark-shell中执行，则可以直接使用已经创建好的SparkSession对象）：
```
val spark = SparkSession.builder()
  .appName("RDD Partition Example")
  .master("local[*]")
  .getOrCreate()
```

创建一个RDD：

val data = Array(1, 2, 3, 4, 5)
val rdd = spark.sparkContext.parallelize(data)

使用getNumPartitions()方法查看RDD的分区数：

val partitionCount = rdd.getNumPartitions()
println(s"RDD的分区数为：$partitionCount")

完整的示例代码如下：

import org.apache.spark.sql.SparkSession

object RDDPartitionExample {
  def main(args: Array[String]): Unit = {
    // 创建SparkSession对象
    val spark = SparkSession.builder()
      .appName("RDD Partition Example")
      .master("local[*]")
      .getOrCreate()

    // 创建RDD
    val data = Array(1, 2, 3, 4, 5)
    val rdd = spark.sparkContext.parallelize(data)

    // 获取RDD的分区数
    val partitionCount = rdd.getNumPartitions()

    // 打印分区数
    println(s"RDD的分区数为：$partitionCount")

    // 关闭SparkSession对象
    spark.stop()
  }
}

运行以上代码，将会输出RDD的分区数