Java 中的通配符不适用于 Spark cogroup 函数

Question

我正在尝试在 java 中合并两个 RDD，其中一个 RDD v2 的类型如下：JavaPairRDD<Key, ? extends Value>（实际上它是用? extends 定义的，因为它是一个函数参数）。

然后当我将它们组合在一起时，例如：

void f(JavaPairRDD<Key, ? extends Value> v2){
    TYPE v = v1. cogroup(v2);
    // ERROR. I cannot get the correct type for this cogroup function
}

编译器抱怨，因为当我尝试从此 cogroup 函数获取返回值时它无法推断 v2 的类型。

有趣的是，如果我不关心返回值，只需调用：

v1.cogroup(v2).collectAsMap();

似乎可行。至少可以编译。

似乎只有在函数参数中将通配符定义为通配符时，java才能接受通配符（如）作为参数。我说的对吗？

我想问是否有另一种方法可以正确地做到这一点？或者也许我不应该这样做，这里到底出了什么问题？

非常感谢。

Answer 1

似乎只有在函数参数中将通配符定义为通配符时，java才能接受通配符（如? extends Base）作为参数。

cogroup是在scala中定义的，由于scala的类型系统支持协变继承，所以它的接口不包含java的keyward extends

  def cogroup[W](other: JavaPairRDD[K, W]): JavaPairRDD[K, (JIterable[V], JIterable[W])] =
    fromRDD(cogroupResultToJava(rdd.cogroup(other)))

但在Java中，如果函数签名中的参数没有通配符，则调用时的参数不能是某种定义为通配符的类型。