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

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

Internal implementation of the Beam runner for Twister2.

Related Packages

Package	Description
org.apache.beam.runners.twister2.translators	Internal implementation of the Beam runner for Twister2.
org.apache.beam.runners.twister2.translators.functions	Internal implementation of the Beam runner for Twister2.
org.apache.beam.runners.twister2.translators.streaming	Internal implementation of the Beam runner for Twister2.

Classes

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