leftOuterJoin JavaPairRDDи JavaPairRDD>

Question

Я пытаюсь выполнить leftOuterJoin для 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>>

Я не смог найти подходящую документацию для этого.Если есть ссылки, чтобы лучше это понять, это тоже было бы полезно.Спасибо.

Answer 1

Согласно javadoc (https://spark.apache.org/docs/2.2.0/api/java/index.html?org/apache/spark/api/java/JavaPairRDD.html), левое внешнее соединение между СДР типа JavaPairRDD<K, V> и СДР типа JavaPairRDD<K,W> даст вам следующее: JavaPairRDD<K,Tuple2<V,Optional<W>>>.

Это то, что вы написали, за исключением того, что тип Optional определен в API Java Java: org.apache.spark.api.java.Optional<T>. Это не то, что определено в Google, поэтому ошибка, которую ваша IDE выдает вам; -)