org.apache.beam.runners.twister2.translators

Class Twister2StreamPipelineTranslator

java.lang.Object

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

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

org.apache.beam.runners.twister2.translators.Twister2StreamPipelineTranslator

All Implemented Interfaces:

Pipeline.PipelineVisitor

public class Twister2StreamPipelineTranslator
extends Twister2PipelineTranslator

Twister pipeline translator for stream 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
Twister2StreamPipelineTranslator(Twister2PipelineOptions options, Twister2TranslationContext twister2TranslationContext)

Method Summary

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, visitPrimitiveTransform, visitValue

Methods inherited from class java.lang.Object

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

Constructor Detail

Twister2StreamPipelineTranslator

public Twister2StreamPipelineTranslator(Twister2PipelineOptions options,
                                        Twister2TranslationContext twister2TranslationContext)