import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}
//map(func)
object sampleRDD {
def main(args: Array[String]): Unit = {
//本地模式
val conf: SparkConf = new SparkConf().setAppName("My scala word count").setMaster("local")
//创建spark上下文对象
val sc = new SparkContext(conf)
val rdd: RDD[Int] = sc.makeRDD(1 to 10)
val value: Any = rdd.sample(true,0.1,0)
println(value)
val ints: Array[Int] = rdd.takeSample(true,3,1)
println(ints.mkString(","))
}
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
