public static interface Pipeline.PipelineVisitor
Pipeline.traverseTopologically(com.google.cloud.dataflow.sdk.Pipeline.PipelineVisitor) to be called for each of the
transforms and values in the Pipeline.| Modifier and Type | Method and Description |
|---|---|
void |
enterCompositeTransform(TransformTreeNode node) |
void |
leaveCompositeTransform(TransformTreeNode node) |
void |
visitTransform(TransformTreeNode node) |
void |
visitValue(PValue value,
TransformTreeNode producer) |
void enterCompositeTransform(TransformTreeNode node)
void leaveCompositeTransform(TransformTreeNode node)
void visitTransform(TransformTreeNode node)
void visitValue(PValue value, TransformTreeNode producer)