Class Twister2PipelineTranslator
java.lang.Object
org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults
org.apache.beam.runners.twister2.translators.Twister2PipelineTranslator
- All Implemented Interfaces:
Pipeline.PipelineVisitor
- Direct Known Subclasses:
Twister2BatchPipelineTranslator
,Twister2StreamPipelineTranslator
Twister2PipelineTranslator, both batch and streaming translators need to extend from this.
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.beam.sdk.Pipeline.PipelineVisitor
Pipeline.PipelineVisitor.CompositeBehavior, Pipeline.PipelineVisitor.Defaults
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults
enterCompositeTransform, enterPipeline, getPipeline, leaveCompositeTransform, leavePipeline, visitPrimitiveTransform, visitValue
-
Constructor Details
-
Twister2PipelineTranslator
public Twister2PipelineTranslator()
-
-
Method Details
-
translate
Translates the pipeline by passing this class as a visitor.- Parameters:
pipeline
- The pipeline to be translated
-