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, Object data)
PhysicalPlan	rewrite(PhysicalPlan currentPhysicalPlan, int messageId)

Method Detail

rewrite

PhysicalPlan rewrite(PhysicalPlan currentPhysicalPlan,
                     int messageId)

Parameters:

currentPhysicalPlan - to rewrite.

messageId - of the rewrite.

Returns:

physical plan.

accumulate

void accumulate(int messageId,
                Object data)

Parameters:

messageId - of the rewrite.

data - to accumulate.