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

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.

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
Twister2PipelineTranslator()

Method Summary

Modifier and Type	Method	Description
void	translate(Pipeline pipeline)	Translates the pipeline by passing this class as a visitor.

Methods inherited from class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults

enterCompositeTransform, enterPipeline, getPipeline, leaveCompositeTransform, leavePipeline, visitPrimitiveTransform, visitValue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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