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

Internal implementation of the Beam runner for Twister2.

See: Description

Interface Summary

Interface	Description
BatchTransformTranslator<TransformT extends PTransform>	Batch TransformTranslator interface.
StreamTransformTranslator<TransformT extends PTransform>	Stream TransformTranslator interface.

Class Summary

Class	Description
Twister2BatchPipelineTranslator	Twister pipeline translator for batch pipelines.
Twister2PipelineTranslator	Twister2PipelineTranslator, both batch and streaming translators need to extend from this.
Twister2StreamPipelineTranslator	Twister pipeline translator for stream pipelines.

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

Internal implementation of the Beam runner for Twister2.