https://github.com/apache/beam/pull/8409 to make this even easier.
On Fri, Apr 26, 2019 at 1:21 AM Nikhil Goyal <[email protected]> wrote: > > Thanks Robert, this is what I was looking for. > > On Thu, Apr 25, 2019 at 4:03 PM Robert Bradshaw <[email protected]> wrote: >> >> You can use the BinaryCombineFn subclass, which only requires >> implementing the (V, V) => V operation. There's also the >> IterableCombineFn which is defined in terms of an Iterable<V> => V. >> >> On Fri, Apr 26, 2019 at 12:53 AM Nikhil Goyal <[email protected]> wrote: >> > >> > 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
