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

Class LookupPipelineVisitor

java.lang.Object

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

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

All Implemented Interfaces:

Pipeline.PipelineVisitor

public class LookupPipelineVisitor
extends Pipeline.PipelineVisitor.Defaults

Pipeline visitor that fills lookup table of PTransform to AppliedPTransform for usage in FlinkBatchPortablePipelineTranslator.BatchTranslationContext.

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

Method Summary

Modifier and Type	Method	Description
Pipeline.PipelineVisitor.CompositeBehavior	enterCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)	Called for each composite transform after all topological predecessors have been visited but before any of its component transforms.
<T extends PValue> T	getInput(PTransform<T,?> transform)
Map<TupleTag<?>,PCollection<?>>	getInputs(PTransform<?,?> transform)
<T extends PValue> T	getOutput(PTransform<?,T> transform)
Map<TupleTag<?>,Coder<?>>	getOutputCoders(PTransform<?,?> transform)
Map<TupleTag<?>,PCollection<?>>	getOutputs(PTransform<?,?> transform)
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

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

LookupPipelineVisitor

public LookupPipelineVisitor()

Method Details

enterCompositeTransform

public Pipeline.PipelineVisitor.CompositeBehavior enterCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)

Description copied from interface: Pipeline.PipelineVisitor

Called for each composite transform after all topological predecessors have been visited but before any of its component transforms.

The return value controls whether or not child transforms are visited.

Specified by:

enterCompositeTransform in interface Pipeline.PipelineVisitor

Overrides:

enterCompositeTransform in class Pipeline.PipelineVisitor.Defaults

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

getInputs

public Map<TupleTag<?>,PCollection<?>> getInputs(PTransform<?,?> transform)

getInput

public <T extends PValue> T getInput(PTransform<T,?> transform)

getOutputs

public Map<TupleTag<?>,PCollection<?>> getOutputs(PTransform<?,?> transform)

getOutput

public <T extends PValue> T getOutput(PTransform<?,T> transform)

getOutputCoders

public Map<TupleTag<?>,Coder<?>> getOutputCoders(PTransform<?,?> transform)