public class GroupByKeyTranslator<K,V> extends java.lang.Object implements TransformTranslator<GroupByKey<K,V>>
GroupByKey
is translated to Gearpump groupBy function.Modifier and Type | Class and Description |
---|---|
protected static class |
GroupByKeyTranslator.GearpumpWindowFn<T,W extends BoundedWindow>
A transform used internally to translate Beam's Window to Gearpump's Window.
|
protected static class |
GroupByKeyTranslator.GroupByFn<K,V>
A transform used internally to group KV message by its key.
|
protected static class |
GroupByKeyTranslator.KeyedByTimestamp<K,V>
A transform used internally to transform WindowedValue to KV.
|
protected static class |
GroupByKeyTranslator.Merge<K,V>
A transform used internally by Gearpump which encapsulates the merge logic.
|
Constructor and Description |
---|
GroupByKeyTranslator() |
Modifier and Type | Method and Description |
---|---|
void |
translate(GroupByKey<K,V> transform,
TranslationContext context) |
public void translate(GroupByKey<K,V> transform, TranslationContext context)
translate
in interface TransformTranslator<GroupByKey<K,V>>