Package org.apache.beam.runners.twister2.translators.batch

Internal implementation of the Beam runner for Twister2.

See: Description

Class Summary

Class	Description
AssignWindowTranslatorBatch<T>	Assign Window translator.
FlattenTranslatorBatch<T>	Flatten translator.
GroupByKeyTranslatorBatch<K,V>	GroupByKey translator.
ParDoMultiOutputTranslatorBatch<InputT,OutputT>	ParDo translator.
PCollectionViewTranslatorBatch<ElemT,ViewT>	PCollectionView translator.
ReadSourceTranslatorBatch<T>	Source translator.

Package org.apache.beam.runners.twister2.translators.batch Description

Internal implementation of the Beam runner for Twister2.