1. import org.apache.spark.rdd.RDD
    2. import org.apache.spark.{SparkConf, SparkContext}
    3. object demo {
    4. def main(args: Array[String]): Unit = {
    5. //创建SparkConf并设置App名称
    6. val conf: SparkConf = new SparkConf().setAppName("SparkCoreTest").setMaster("local[*]")
    7. //创建SparkContext,该对象是提交Spark App的入口
    8. val sc: SparkContext = new SparkContext(conf)
    9. val rdd: RDD[Int] = sc.makeRDD(1 to 10)
    10. //从集合里面随机取三个出来
    11. /* 参数1 : 取出来是否放回去,false取出来不放回去, true,取出来放回去.
    12. 参数2: 取出来数量
    13. */
    14. val ints = rdd.takeSample(false, 3)
    15. println(ints.mkString(",")) //输出: 5,3,7
    16. // 关闭连接
    17. sc.stop()
    18. }
    19. }