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

本文主要是介绍第五章_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()
  }

这篇关于第五章_Spark核心编程_Rdd_行动算子_take的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！