protected static class GroupByKeyTranslator.GroupByFn<K,V> extends io.gearpump.streaming.dsl.javaapi.functions.GroupByFunction<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>,java.nio.ByteBuffer>
Modifier and Type | Method and Description |
---|---|
java.nio.ByteBuffer |
groupBy(org.apache.beam.sdk.util.WindowedValue<KV<K,V>> wv) |