org.apache.beam.runners.gearpump.translators

Class GroupByKeyTranslator<K,V>

java.lang.Object

org.apache.beam.runners.gearpump.translators.GroupByKeyTranslator<K,V>

All Implemented Interfaces:

java.io.Serializable, TransformTranslator<GroupByKey<K,V>>

public class GroupByKeyTranslator<K,V>
extends java.lang.Object
implements TransformTranslator<GroupByKey<K,V>>

GroupByKey is translated to Gearpump groupBy function.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

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 Summary

Constructors

Constructor and Description
GroupByKeyTranslator()

Method Summary

Modifier and Type	Method and Description
void	translate(GroupByKey<K,V> transform, TranslationContext context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GroupByKeyTranslator

public GroupByKeyTranslator()

Method Detail

translate

public void translate(GroupByKey<K,V> transform,
                      TranslationContext context)

Specified by:

translate in interface TransformTranslator<GroupByKey<K,V>>