Package org.apache.beam.runners.flink.translation.utils

Class CountingPipelineVisitor

java.lang.Object

org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults

org.apache.beam.runners.flink.translation.utils.CountingPipelineVisitor

All Implemented Interfaces:

Pipeline.PipelineVisitor

public class CountingPipelineVisitor
extends Pipeline.PipelineVisitor.Defaults

Pipeline visitors that fills a lookup table of PValue to number of consumers.

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
CountingPipelineVisitor()

Method Summary

Modifier and Type	Method	Description
int	getNumConsumers(PValue value)	Calculate number of consumers of a given PValue.
void	visitPrimitiveTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)	Called for each primitive transform after all of its topological predecessors and inputs have been visited.

Methods inherited from class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults

enterCompositeTransform, enterPipeline, getPipeline, leaveCompositeTransform, leavePipeline, visitValue

Methods inherited from class java.lang.Object

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

Constructor Details

CountingPipelineVisitor

public CountingPipelineVisitor()

Method Details

visitPrimitiveTransform

public void visitPrimitiveTransform(org.apache.beam.sdk.runners.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 interface Pipeline.PipelineVisitor

Overrides:

visitPrimitiveTransform in class Pipeline.PipelineVisitor.Defaults

getNumConsumers

public int getNumConsumers(PValue value)

Calculate number of consumers of a given PValue.

Parameters:

value - PValue to perform calculation for.

Returns:

Number of consumers.