我正在尝试执行leftOuterJoin of JavaPairRDD和JavaPairRDD>,在函数中,签名返回类型是
JavaPairRDD<Integer, Tuple2<Integer, Optional<Map<Integer, Integer>>>>可选这里是com.google.common.base.Optional
当我执行leftOuterJoin时,这是正确的返回类型吗?
我的IDE出现了这个错误
no instance(s) of type variable(s) W exist so that Optinal<W> conforms to Optional<Map<Integer, Integer>>我找不到合适的文件。如果有任何链接来更好地理解这一点,那也是有帮助的。谢谢。
发布于 2018-05-16 06:36:03
根据javadoc (https://spark.apache.org/docs/2.2.0/api/java/index.html?org/apache/spark/api/java/JavaPairRDD.html),JavaPairRDD<K, V>类型的RDD与JavaPairRDD<K,W>类型的RDD之间的左外部连接将给出如下结果:JavaPairRDD<K,Tuple2<V,Optional<W>>>。
这就是您所写的内容,只是在spark的java:org.apache.spark.api.java.Optional<T>中定义了可选类型。它不是由Google定义的,因此IDE向您抛出错误;-)
https://stackoverflow.com/questions/50363487
复制相似问题