org.apache.beam.runners.twister2.translators.Twister2BatchPipelineTranslator

public class Twister2BatchPipelineTranslator extends Twister2PipelineTranslator

Twister pipeline translator for batch pipelines.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.Pipeline.PipelineVisitor
Pipeline.PipelineVisitor.CompositeBehavior, Pipeline.PipelineVisitor.Defaults
Constructor Summary

Constructors

Constructor

Description

Twister2BatchPipelineTranslator(Twister2PipelineOptions options, Twister2BatchTranslationContext twister2TranslationContext)
Method Summary

Modifier and Type

Method

Description

void

visitPrimitiveTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)

Called for each primitive transform after all of its topological predecessors and inputs have been visited.

Methods inherited from class org.apache.beam.runners.twister2.translators.Twister2PipelineTranslator
translate

Methods inherited from class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults
enterCompositeTransform, enterPipeline, getPipeline, leaveCompositeTransform, leavePipeline, visitValue

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- Twister2BatchPipelineTranslator
  
  public Twister2BatchPipelineTranslator(Twister2PipelineOptions options, Twister2BatchTranslationContext twister2TranslationContext)
Method Details
- visitPrimitiveTransform
  
  public void visitPrimitiveTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)
  
  Description copied from interface: Pipeline.PipelineVisitor
  
  Called for each primitive transform after all of its topological predecessors and inputs have been visited.
  
  Specified by:
  
  visitPrimitiveTransform in interface Pipeline.PipelineVisitor
  
  Overrides:
  
  visitPrimitiveTransform in class Pipeline.PipelineVisitor.Defaults

Class Twister2BatchPipelineTranslator

Nested Class Summary