cogroup(otherStream, [numTasks])

cogroup(otherStream, [numTasks])

When called on a DStream of (K, V) and (K, W) pairs, return a new DStream of (K, (Seq[V], Seq[W])) tuples.
1
inputStream.cogroup(inputStream)
2
​
3
/*
4
res5: org.apache.spark.streaming.dstream.DStream[(Int, (Iterable[Int], Iterable[Int]))] = [email protected]
5
*/
Copied!
Last modified 1yr ago
Copy link