import org.apache.spark.rdd.RDD
import 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()
}
}