1)函数签名:def count(): Long
    2)功能说明:返回RDD中元素的个数
    image.png

    1. import org.apache.spark.rdd.RDD
    2. import org.apache.spark.{SparkConf, SparkContext}
    3. object action01_reduce {
    4. def main(args: Array[String]): Unit = {
    5. //1.创建SparkConf并设置App名称
    6. val conf: SparkConf = new SparkConf().setAppName("SparkCoreTest").setMaster("local[*]")
    7. //2.创建SparkContext,该对象是提交Spark App的入口
    8. val sc: SparkContext = new SparkContext(conf)
    9. //3具体业务逻辑
    10. //3.1 创建第一个RDD
    11. val rdd: RDD[Int] = sc.makeRDD(List(1, 2, 3, 4))
    12. //3.2 返回RDD中元素的个数
    13. val countResult: Long = rdd.count()
    14. println(countResult)
    15. //4.关闭连接
    16. sc.stop()
    17. }
    18. }