Package org.apache.nemo.runtime.common.plan

Interface PlanRewriter

All Known Implementing Classes:

NemoPlanRewriter

public interface PlanRewriter

PhysicalPlan rewriter.

Method Summary

Modifier and Type	Method	Description
void	accumulate(int messageId, java.util.Set<StageEdge> targetEdges, java.lang.Object data)
PhysicalPlan	rewrite(int messageId)

Method Detail

rewrite

PhysicalPlan rewrite(int messageId)

Parameters:

messageId - of the rewrite.

Returns:

physical plan.

accumulate

void accumulate(int messageId,
                java.util.Set<StageEdge> targetEdges,
                java.lang.Object data)

Parameters:

messageId - of the rewrite.

data - to accumulate.