RDD_行动算子first take count

常见的获取行动算子：

1. first算子：取出RDD的第一个元素
2. take算子：取出RDD的前n个元素，组成一个Array返回
3. 统计数量行动算子count：计算RDD有多少个元素

xxxxxxxxxx
package com.itbaizhan.rdd.action

//1.导入类
import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object RddFirstTakeCount {
  def main(args: Array[String]): Unit = {
    //2.构建SparkConf对象，并设置本地运行和程序名称
    val conf: SparkConf = new SparkConf().setMaster("local[1]").
      setAppName("FirstTakeCount")
    //3.使用conf对象构建SparkContet对象
    val sc = new SparkContext(conf)
    //5.创建RDD对象
    val rdd: RDD[Int] = sc.parallelize(List(5, 2, 1, 4, 3, 8, 6, 1))
    //6.获取第一个元素
    val first: Int = rdd.first()
    println("first:"+first)
    //7.获取rdd前三个元素
    val threeEle: Array[Int] = rdd.take(3)
    println(threeEle.mkString(","))
    //8.获取rdd中元素的总数
    val eleNum: Long = rdd.count()
    println(eleNum)
    //4.关闭sc对象
    sc.stop()
  }
}

运行结果：

xxxxxxxxxx
first:5
5,2,1
8

实时效果反馈

1. 以下关于rdd = sc.parallelize(List(5,2,1,4,3,8,6,1))中rdd相关算子的描述正确的是：

A rdd.first()取出rdd的第一个元素。

B rdd.take(4)取出rdd的前4个元素，组成一个Array返回。

C rdd.count()计算rdd有多少个元素，结果为8。

D 以上三个选项都正确。

答案：

1=>D