public class GearpumpPipelineTranslator extends Pipeline.PipelineVisitor.Defaults
Pipeline.PipelineVisitor.CompositeBehavior, Pipeline.PipelineVisitor.Defaults
Constructor and Description |
---|
GearpumpPipelineTranslator(TranslationContext translationContext) |
Modifier and Type | Method and 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.
|
void |
leaveCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)
Called for each composite transform after all of its component transforms and their outputs
have been visited.
|
void |
translate(Pipeline pipeline) |
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.
|
void |
visitValue(PValue value,
org.apache.beam.sdk.runners.TransformHierarchy.Node producer)
Called for each value after the transform that produced the value has been visited.
|
enterPipeline, getPipeline, leavePipeline
public GearpumpPipelineTranslator(TranslationContext translationContext)
public void translate(Pipeline pipeline)
public Pipeline.PipelineVisitor.CompositeBehavior enterCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)
Pipeline.PipelineVisitor
The return value controls whether or not child transforms are visited.
enterCompositeTransform
in interface Pipeline.PipelineVisitor
enterCompositeTransform
in class Pipeline.PipelineVisitor.Defaults
public void leaveCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)
Pipeline.PipelineVisitor
leaveCompositeTransform
in interface Pipeline.PipelineVisitor
leaveCompositeTransform
in class Pipeline.PipelineVisitor.Defaults
public void visitPrimitiveTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node node)
Pipeline.PipelineVisitor
visitPrimitiveTransform
in interface Pipeline.PipelineVisitor
visitPrimitiveTransform
in class Pipeline.PipelineVisitor.Defaults
public void visitValue(PValue value, org.apache.beam.sdk.runners.TransformHierarchy.Node producer)
Pipeline.PipelineVisitor
visitValue
in interface Pipeline.PipelineVisitor
visitValue
in class Pipeline.PipelineVisitor.Defaults