Hi guys,

Given a PCollection<K, V> and a method (V, V) => V, is there a way to
reduce the Key Value pairs?
I see there is GroupBy which returns Iterator<V> and it might not be cost
effective. The combine method requires to implement interface
CombineFn which makes the code go extremely verbose. I was wondering if we
have something similar to spark api of reduce in beam as well.

Thanks
Nikhil

Reply via email to