Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
Group together values with same key from both streams. Similar constructs are supported in beam, spark and flink.
When called on a Stream of (K, V) and (K, W) pairs, return a new Stream of (K, Seq[V], Seq[W]) tuples
See also - https://cloud.google.com/dataflow/model/group-by-key