Advertisement
Guest User

Untitled

a guest
May 3rd, 2016
44
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.65 KB | None | 0 0
  1. JavaPairRDD<String, Tuple2<SomeModelClass, Optional<SomeModelClass>>> join = RDD1.leftOuterJoin(RDD2);
  2.  
  3. JavaRDD<SomeModelClass> joinMap = join
  4. .map(tuple -> {
  5. Tuple2<SomeModelClass, Optional<SomeModelClass>> _2 = tuple._2();
  6. SomeModelClass RDD1 = _2._1();
  7. Optional<SomeModelClass> RDD2 = _2._2();
  8. SomeModelClass SomeModelClass = new SomeModelClass();
  9.  
  10. if(!RDD1.ispresent && someColumn==y){
  11. //join with RDD3 get some values
  12. return results
  13. } else
  14.  
  15. //join with some other RDDD
  16.  
  17.  
  18. return SomeModelClass;
  19. });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement