edu.snu.coral.compiler.frontend.beam

Class CoralPipelineVisitor

java.lang.Object

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

edu.snu.coral.compiler.frontend.beam.CoralPipelineVisitor

All Implemented Interfaces:

org.apache.beam.sdk.Pipeline.PipelineVisitor

public final class CoralPipelineVisitor
extends org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults

Visits every node in the beam dag to translate the BEAM program to the IR.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.Pipeline.PipelineVisitor

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

Constructor Summary

Constructors

Constructor and Description
CoralPipelineVisitor(DAGBuilder<IRVertex,IREdge> builder, org.apache.beam.sdk.options.PipelineOptions options) Constructor of the BEAM Visitor.

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.Pipeline.PipelineVisitor.CompositeBehavior	enterCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node beamNode)
void	leaveCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node beamNode)
void	visitPrimitiveTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node beamNode)

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

visitValue

Methods inherited from class java.lang.Object

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

Constructor Detail

CoralPipelineVisitor

public CoralPipelineVisitor(DAGBuilder<IRVertex,IREdge> builder,
                            org.apache.beam.sdk.options.PipelineOptions options)

Constructor of the BEAM Visitor.

Parameters:

builder - DAGBuilder to build the DAG with.

options - Pipeline options.

Method Detail

enterCompositeTransform

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

Specified by:

enterCompositeTransform in interface org.apache.beam.sdk.Pipeline.PipelineVisitor

Overrides:

enterCompositeTransform in class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults

leaveCompositeTransform

public void leaveCompositeTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node beamNode)

Specified by:

leaveCompositeTransform in interface org.apache.beam.sdk.Pipeline.PipelineVisitor

Overrides:

leaveCompositeTransform in class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults

visitPrimitiveTransform

public void visitPrimitiveTransform(org.apache.beam.sdk.runners.TransformHierarchy.Node beamNode)

Specified by:

visitPrimitiveTransform in interface org.apache.beam.sdk.Pipeline.PipelineVisitor

Overrides:

visitPrimitiveTransform in class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults