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