在/core/src/main/scala/org/apache/spark/SparkContext.scala的火花文件中,有以下是rdd:RDD [(K,V)]中的RDD [(K,V)]類型?
implicit def rddToPairRDDFunctions[K, V](rdd: RDD[(K, V)])
(implicit kt: ClassTag[K], vt: ClassTag[V], ord: Ordering[K] = null) = {
new PairRDDFunctions(rdd)
}
我認爲RDD [(K,V)]爲類型rdd的旁白。但是,我們如何定義類似RDD [(K,V)]? 下面無法編譯
abstract class RDD[(K, V)]
但是下面可能。
abstract class RDD[K, V]
那麼什麼是RDD [(K,V)]