• Note: Users should not be using GroupByKey transforms directly. Use instead GroupBy, and Combine transforms.

    GroupByKey is the primitive transform in Beam to force shuffling of data, which helps us group data of the same key together. It's a necessary primitive for any Beam SDK.

    GroupByKey operations are used under the hood to execute combines, streaming triggers, stateful transforms, etc.

    Type Parameters

    • K

    • V

    Returns PTransform<PCollection<KV<K, V>>, PCollection<KV<K, Iterable<V>>>>

Generated using TypeDoc