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:

SparkRunner.Evaluator

Enclosing interface:

Pipeline.PipelineVisitor

public static class Pipeline.PipelineVisitor.Defaults
extends java.lang.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 and Description
Defaults()

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	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 Detail

Defaults

public Defaults()

Method Detail

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