So I have an RDD of something like this
RDD[(Int, List)]]
Where a single element in the RDD looks like
(1, List(1, 2, 3))
My question is how can I expand the key value pair to something like this
(1,1)
(1,2)
(1,3)
Thank you
rdd.flatMap { case (key, values) => values.map((key, _)) }
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With