说明

相当于 SQL 中的 count()

返回 RDD 中元素的个数

声明

def count(): Long

返回值：Long型，RDD 中元素的个数

例子

val sparConf = new SparkConf().setMaster("local[*]").setAppName("RDD")
val sc = new SparkContext(sparConf)

val rdd:RDD[Int] = sc.makeRDD( List( 1,2,3,4,5,6,4,5,6 ),2 )

val count:Long=rdd.count()
println(count)
sc.stop()

执行结果：

9

没有去重

原文出处：/show_1IX1Nz5rvPq3.html