com.google.cloud.dataflow.sdk

Interface Pipeline.PipelineVisitor

All Known Implementing Classes:

RecordingPipelineVisitor

Enclosing class:

Pipeline

public static interface Pipeline.PipelineVisitor

A PipelineVisitor can be passed into Pipeline.traverseTopologically(com.google.cloud.dataflow.sdk.Pipeline.PipelineVisitor) to be called for each of the transforms and values in the Pipeline.

Method Summary

Methods

Modifier and Type	Method and Description
void	enterCompositeTransform(TransformTreeNode node)
void	leaveCompositeTransform(TransformTreeNode node)
void	visitTransform(TransformTreeNode node)
void	visitValue(PValue value, TransformTreeNode producer)

Method Detail

enterCompositeTransform

void enterCompositeTransform(TransformTreeNode node)

leaveCompositeTransform

void leaveCompositeTransform(TransformTreeNode node)

visitTransform

void visitTransform(TransformTreeNode node)

visitValue

void visitValue(PValue value,
              TransformTreeNode producer)