0
我想声明一个函数来得到两个RDD
的cogroup
。其实这是一个interSectionByKey
。下面的代码不能编译:如何声明函数来调用cogroup
def getRetain[K, V](activeUserRdd : RDD[(K, V)], newUserRdd : RDD[(K, V)]): RDD[(K, V)] ={
activeUserRdd.cogroup(newUserRdd).flatMapValues{
x => Option((if (!x._1.isEmpty && !x._2.isEmpty) x._2.head else null).asInstanceOf[V])
}
}
错误:
value cogroup is not a member of org.apache.spark.rdd.RDD[(K, V)]
我觉得(K, V)
匹配小姐在cogroup
声明的真正[(K, V)]
,但是这是在我的函数声明的正确方法?
我没有这个包scala.reflect.TypeTag,你知道一些其他的解决方案,只是使用原来的阶。我认为它可以帮助我理解scala。 编译时发生错误。谢谢。 – yyforever1988
对不起,我打错输入。请再试一次。 –
它的工作,谢谢 – yyforever1988