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

Internal implementation of the Beam runner for Apache Flink.

See: Description

Interface Summary

Interface	Description
BatchTransformTranslator<TransformT extends PTransform>	doc.
StreamTransformTranslator<TransformT extends PTransform>	doc.

Class Summary

Class	Description
Twister2BatchPipelineTranslator	Twister pipeline translator for batch pipelines.
Twister2PipelineTranslator	doc.
Twister2StreamPipelineTranslator	doc.

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

Internal implementation of the Beam runner for Apache Flink.