2
我试着写了下面的方法:错误:值连接不是org.apache.spark.rdd.RDD [(Long,U)]的成员?
scala> def isEqual[U, V](expected: RDD[U], result: RDD[V]) = {
| val expectedIndexValue: RDD[(Long, U)] = expected.zipWithIndex().map{ case (row, idx) => (idx, row) }
| val resultIndexValue: RDD[(Long, V)] = result.zipWithIndex().map{ case (row, idx) => (idx, row) }
| val combined = expectedIndexValue.join(resultIndexValue)
| }
但我得到了以下错误:
<console>:52: error: value join is not a member of org.apache.spark.rdd.RDD[(Long, U)]
val combined = expectedIndexValue.join(resultIndexValue)
你刚刚在我的同一时间回答,所以他正在斯卡拉运行Spark解释器?他不需要在某个地方打电话吗?或者他的方法是什么?很高兴删除我的答案,如果我远离基地感谢 – JimLohse
耶,这是scala语法正在使用。 – Holden
我明白了,但是他不需要在某个地方打电话来创建RDD吗? – JimLohse