org.apache.beam.runners.twister2.translators

Class Twister2BatchPipelineTranslator

java.lang.Object

org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults

org.apache.beam.runners.twister2.translators.Twister2PipelineTranslator

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

All Implemented Interfaces:

Pipeline.PipelineVisitor

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 and Description
Twister2BatchPipelineTranslator(Twister2PipelineOptions options, Twister2BatchTranslationContext twister2TranslationContext)

Method Summary

Modifier and Type	Method and 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 Detail

Twister2BatchPipelineTranslator

public Twister2BatchPipelineTranslator(Twister2PipelineOptions options,
                                       Twister2BatchTranslationContext twister2TranslationContext)

Method Detail

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