Package org.apache.beam.sdk
Class Pipeline.PipelineVisitor.Defaults
- java.lang.Object
-
- org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults
-
- All Implemented Interfaces:
Pipeline.PipelineVisitor
- Enclosing interface:
- Pipeline.PipelineVisitor
public static class Pipeline.PipelineVisitor.Defaults extends java.lang.Object implements Pipeline.PipelineVisitor
Default no-opPipeline.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Pipeline.PipelineVisitor.CompositeBehavior
enterCompositeTransform(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 thePipeline
object itself.protected Pipeline
getPipeline()
void
leaveCompositeTransform(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 aPipeline
have been visited.void
visitPrimitiveTransform(TransformHierarchy.Node node)
Called for each primitive transform after all of its topological predecessors and inputs have been visited.void
visitValue(PValue value, TransformHierarchy.Node producer)
Called for each value after the transform that produced the value has been visited.
-
-
-
Method Detail
-
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 thePipeline
object itself.- Specified by:
enterPipeline
in interfacePipeline.PipelineVisitor
-
enterCompositeTransform
public Pipeline.PipelineVisitor.CompositeBehavior enterCompositeTransform(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 interfacePipeline.PipelineVisitor
-
leaveCompositeTransform
public void leaveCompositeTransform(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 interfacePipeline.PipelineVisitor
-
visitPrimitiveTransform
public void visitPrimitiveTransform(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 interfacePipeline.PipelineVisitor
-
visitValue
public void visitValue(PValue value, 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 interfacePipeline.PipelineVisitor
-
leavePipeline
public void leavePipeline(Pipeline pipeline)
Description copied from interface:Pipeline.PipelineVisitor
Called when all values and transforms in aPipeline
have been visited.- Specified by:
leavePipeline
in interfacePipeline.PipelineVisitor
-
-