Package org.apache.beam.sdk

Class Pipeline.PipelineVisitor.Defaults

java.lang.Object

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

All Implemented Interfaces:

Pipeline.PipelineVisitor

Direct Known Subclasses:

CountingPipelineVisitor, GroupByKeyVisitor, LookupPipelineVisitor, SparkRunner.Evaluator, Twister2PipelineTranslator

Enclosing interface:

Pipeline.PipelineVisitor

public static class Pipeline.PipelineVisitor.Defaults
extends Object
implements Pipeline.PipelineVisitor

Default no-op Pipeline.PipelineVisitor that enters all composite transforms. User implementations can override just those methods they are interested in.

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

Method Summary

Modifier and Type	Method	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	enterPipeline(Pipeline pipeline)	Called before visiting anything values or transforms, as many uses of a visitor require access to the Pipeline object itself.
protected Pipeline	getPipeline()
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	leavePipeline(Pipeline pipeline)	Called when all values and transforms in a Pipeline have been visited.
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 java.lang.Object

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

Constructor Details

Defaults

public Defaults()

Method Details

getPipeline

protected Pipeline getPipeline()

enterPipeline

public void enterPipeline(Pipeline pipeline)

Description copied from interface: Pipeline.PipelineVisitor

Called before visiting anything values or transforms, as many uses of a visitor require access to the Pipeline object itself.

Specified by:

enterPipeline in interface Pipeline.PipelineVisitor

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

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

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

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

leavePipeline

public void leavePipeline(Pipeline pipeline)

Description copied from interface: Pipeline.PipelineVisitor

Called when all values and transforms in a Pipeline have been visited.

Specified by:

leavePipeline in interface Pipeline.PipelineVisitor