第五章_Spark核心编程_Rdd_行动算子_take

1.定义

  /*
* 1.定义
*     def take(num: Int): Array[T]
* 2.功能
*     返回一个由 RDD 的前 n 个元素组成的数组
*
* */

2.示例

  object takeTest extends App {

    val sparkconf: SparkConf = new SparkConf().setMaster("local").setAppName("distinctTest")

    val sc: SparkContext = new SparkContext(sparkconf)

    private val rdd: RDD[Int] = sc.makeRDD(List(8, 2, 4, 2), 4)

    private val result = rdd.take(3)

    println(result)

    sc.stop()
  }