Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk
Interface Pipeline.PipelineVisitor
-
- All Known Implementing Classes:
- RecordingPipelineVisitor
- Enclosing class:
- Pipeline
public static interface Pipeline.PipelineVisitorAPipeline.PipelineVisitorcan be passed intoPipeline.traverseTopologically(com.google.cloud.dataflow.sdk.Pipeline.PipelineVisitor)to be called for each of the transforms and values in thePipeline.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description voidenterCompositeTransform(TransformTreeNode node)Called for each composite transform after all topological predecessors have been visited but before any of its component transforms.voidleaveCompositeTransform(TransformTreeNode node)Called for each composite transform after all of its component transforms and their outputs have been visited.voidvisitTransform(TransformTreeNode node)Called for each primitive transform after all of its topological predecessors and inputs have been visited.voidvisitValue(PValue value, TransformTreeNode producer)Called for each value after the transform that produced the value has been visited.
-
-
-
Method Detail
-
enterCompositeTransform
void enterCompositeTransform(TransformTreeNode node)
Called for each composite transform after all topological predecessors have been visited but before any of its component transforms.
-
leaveCompositeTransform
void leaveCompositeTransform(TransformTreeNode node)
Called for each composite transform after all of its component transforms and their outputs have been visited.
-
visitTransform
void visitTransform(TransformTreeNode node)
Called for each primitive transform after all of its topological predecessors and inputs have been visited.
-
visitValue
void visitValue(PValue value, TransformTreeNode producer)
Called for each value after the transform that produced the value has been visited.
-
-