protected static class GroupByKeyTranslator.Merge<K,V> extends org.apache.gearpump.streaming.dsl.api.functions.FoldFunction<KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,V>>>,KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,java.util.List<V>>>>>
Modifier and Type | Method and Description |
---|---|
KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,java.util.List<V>>>> |
fold(KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,java.util.List<V>>>> accum,
KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,V>>> iter) |
KV<Instant,org.apache.beam.sdk.util.WindowedValue<KV<K,java.util.List<V>>>> |
init() |