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

public abstract class Twister2PipelineTranslator extends Pipeline.PipelineVisitor.Defaults
Twister2PipelineTranslator, both batch and streaming translators need to extend from this.
  • Constructor Details

    • Twister2PipelineTranslator

      public Twister2PipelineTranslator()
  • Method Details

    • translate

      public void translate(Pipeline pipeline)
      Translates the pipeline by passing this class as a visitor.
      Parameters:
      pipeline - The pipeline to be translated