val a = sc.parallelize(Array(("123",4.0),("456",9.0),("789",9.0))

val b = sc.parallelize(Array(("123",8.0),("789",10)))

val c = a.join(b)

c.foreach(println)

/*

(123,(4.0,8.0))

(789,(9.0,10))

*/

val d = a.cogroup(b)

d.foreach(println)

/*

(456,(CompactBuffer(9.0),CompactBuffer()))

(123,(CompactBuffer(4.0),CompactBuffer(8.0)))

(789,(CompactBuffer(9.0),CompactBuffer(10)))

*/

val e = a.leftOuterJoin(b)

e.foreach(println)

/*

(456,(9.0,None))

(123,(4.0,Some(8.0)))

(789,(9.0,Some(10)))

*/

val f = a.fullOuterJoin(b)

f.foreach(println)

/*

(456,(Some(9.0),None))

(123,(Some(4.0),Some(8.0)))

(789,(Some(9.0),Some(10)))

*/

val g = a.cartesian(b)

g.foreach(println)

/*

((123,4.0),(123,8.0))

((123,4.0),(789,10))

((456,9.0),(123,8.0))

((456,9.0),(789,10))

((789,9.0),(123,8.0))

((789,9.0),(789,10))

*/

/*val h = a.coalesce(6,true)

h.foreach(println)

a.dependencies.foreach(println)*/

val i = a.keyBy{case (k,v)=>("haha",234)}

i.foreach(println)

/*

((haha,234),(123,4.0))

((haha,234),(456,9.0))

((haha,234),(789,9.0))

*/