Package org.apache.beam.runners.gearpump.translators

Gearpump specific translators.

See: Description

Interface Summary

Interface	Description
TransformTranslator<T extends PTransform>	Translates PTransform to Gearpump functions.

Class Summary

Class	Description
CreateGearpumpPCollectionViewTranslator<ElemT,ViewT>	CreateGearpumpPCollectionView bridges input stream to down stream transforms.
FlattenPCollectionsTranslator<T>	Flatten.FlattenPCollectionList is translated to Gearpump merge function.
GearpumpPipelineTranslator	GearpumpPipelineTranslator knows how to translate Pipeline objects into Gearpump Graph.
GroupByKeyTranslator<K,V>	GroupByKey is translated to Gearpump groupBy function.
GroupByKeyTranslator.GearpumpWindowFn<T,W extends BoundedWindow>	A transform used internally to translate Beam's Window to Gearpump's Window.
GroupByKeyTranslator.GroupByFn<K,V>	A transform used internally to group KV message by its key.
GroupByKeyTranslator.KeyedByTimestamp<K,V>	A transform used internally to transform WindowedValue to KV.
GroupByKeyTranslator.Merge<K,V>	A transform used internally by Gearpump which encapsulates the merge logic.
ParDoMultiOutputTranslator<InputT,OutputT>	ParDo.MultiOutput is translated to Gearpump flatMap function with DoFn wrapped in DoFnFunction.
ReadBoundedTranslator<T>	Read.Bounded is translated to Gearpump source function and BoundedSource is wrapped into Gearpump DataSource.
ReadUnboundedTranslator<T>	Read.Unbounded is translated to Gearpump source function and UnboundedSource is wrapped into Gearpump DataSource.
TranslationContext	Maintains context data for TransformTranslators.
WindowAssignTranslator<T>	Window.Assign is translated to Gearpump flatMap function.
WindowAssignTranslator.AssignWindows<T>	A Function used internally by Gearpump to wrap the actual Beam's WindowFn.

Package org.apache.beam.runners.gearpump.translators Description

Gearpump specific translators.