org.apache.beam.runners.gearpump.translators

Class GearpumpPipelineTranslator

java.lang.Object

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

org.apache.beam.runners.gearpump.translators.GearpumpPipelineTranslator

All Implemented Interfaces:

Pipeline.PipelineVisitor

public class GearpumpPipelineTranslator
extends Pipeline.PipelineVisitor.Defaults

GearpumpPipelineTranslator knows how to translate Pipeline objects into Gearpump Graph.

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
GearpumpPipelineTranslator(TranslationContext translationContext)

Method Summary

Modifier and Type	Method and Description
Pipeline.PipelineVisitor.CompositeBehavior	enterCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node) Called for each composite transform after all topological predecessors have been visited but before any of its component transforms.
void	leaveCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node) Called for each composite transform after all of its component transforms and their outputs have been visited.
void	translate(Pipeline pipeline)
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.
void	visitValue(PValue value, org.apache.beam.sdk.runners.TransformHierarchy.Node producer) Called for each value after the transform that produced the value has been visited.

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

enterPipeline, getPipeline, leavePipeline

Methods inherited from class java.lang.Object

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

Constructor Detail

GearpumpPipelineTranslator

public GearpumpPipelineTranslator(TranslationContext translationContext)

Method Detail

translate

public void translate(Pipeline pipeline)

enterCompositeTransform

public Pipeline.PipelineVisitor.CompositeBehavior enterCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)

Description copied from interface: Pipeline.PipelineVisitor

Called for each composite transform after all topological predecessors have been visited but before any of its component transforms.

The return value controls whether or not child transforms are visited.

Specified by:

enterCompositeTransform in interface Pipeline.PipelineVisitor

Overrides:

enterCompositeTransform in class Pipeline.PipelineVisitor.Defaults

leaveCompositeTransform

public void leaveCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)

Description copied from interface: Pipeline.PipelineVisitor

Called for each composite transform after all of its component transforms and their outputs have been visited.

Specified by:

leaveCompositeTransform in interface Pipeline.PipelineVisitor

Overrides:

leaveCompositeTransform in class Pipeline.PipelineVisitor.Defaults

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

visitValue

public void visitValue(PValue value,
                       org.apache.beam.sdk.runners.TransformHierarchy.Node producer)

Description copied from interface: Pipeline.PipelineVisitor

Called for each value after the transform that produced the value has been visited.

Specified by:

visitValue in interface Pipeline.PipelineVisitor

Overrides:

visitValue in class Pipeline.PipelineVisitor.Defaults