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

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

Internal implementation of the Beam runner for Twister2.

Related Packages

Package	Description
org.apache.beam.runners.twister2	Internal implementation of the Beam runner for Twister2.
org.apache.beam.runners.twister2.translators.batch	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.
org.apache.beam.runners.twister2.utils	Internal implementation of the Beam runner for Twister2.

Class	Description
BatchTransformTranslator<TransformT extends PTransform>	Batch TransformTranslator interface.
StreamTransformTranslator<TransformT extends PTransform>	Stream TransformTranslator interface.
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.