com.google.cloud.dataflow.sdk.runners

Class RecordingPipelineVisitor

java.lang.Object

com.google.cloud.dataflow.sdk.runners.RecordingPipelineVisitor

All Implemented Interfaces:

Pipeline.PipelineVisitor

public class RecordingPipelineVisitor
extends Object
implements Pipeline.PipelineVisitor

Provides a simple Pipeline.PipelineVisitor that records the transformation tree.

Provided for internal unit tests.

Field Summary

Fields

Modifier and Type	Field and Description
List<PTransform<?,?>>	transforms
List<PValue>	values

Constructor Summary

Constructors

Constructor and Description
RecordingPipelineVisitor()

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

transforms

public final List<PTransform<?,?>> transforms

values

public final List<PValue> values

Constructor Detail

RecordingPipelineVisitor

public RecordingPipelineVisitor()

Method Detail

enterCompositeTransform

public void enterCompositeTransform(TransformTreeNode node)

Specified by:

enterCompositeTransform in interface Pipeline.PipelineVisitor

leaveCompositeTransform

public void leaveCompositeTransform(TransformTreeNode node)

Specified by:

leaveCompositeTransform in interface Pipeline.PipelineVisitor

visitTransform

public void visitTransform(TransformTreeNode node)

Specified by:

visitTransform in interface Pipeline.PipelineVisitor

visitValue

public void visitValue(PValue value,
              TransformTreeNode producer)

Specified by:

visitValue in interface Pipeline.PipelineVisitor