Class DefaultPolicyWithSeparatePass
- java.lang.Object
-
- org.apache.nemo.compiler.optimizer.policy.DefaultPolicyWithSeparatePass
-
- All Implemented Interfaces:
java.io.Serializable
,Policy
public final class DefaultPolicyWithSeparatePass extends java.lang.Object implements Policy
A simple example policy to demonstrate a policy with a separate, refactored pass. It simply performs what is done with the default pass. This example simply shows that users can define their own pass in their policy.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
DefaultPolicyWithSeparatePass.RefactoredPass
A simple custom pass consisted of the two passes at the end of the default pass.
-
Field Summary
Fields Modifier and Type Field Description static PolicyBuilder
BUILDER
-
Constructor Summary
Constructors Constructor Description DefaultPolicyWithSeparatePass()
Default constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description IRDAG
runCompileTimeOptimization(IRDAG dag, java.lang.String dagDirectory)
Optimize the DAG with the compile-time optimizations.IRDAG
runRunTimeOptimizations(IRDAG dag, Message<?> message)
Optimize the DAG with the run-time optimizations.
-
-
-
Field Detail
-
BUILDER
public static final PolicyBuilder BUILDER
-
-
Method Detail
-
runCompileTimeOptimization
public IRDAG runCompileTimeOptimization(IRDAG dag, java.lang.String dagDirectory)
Description copied from interface:Policy
Optimize the DAG with the compile-time optimizations.- Specified by:
runCompileTimeOptimization
in interfacePolicy
- Parameters:
dag
- input DAG.dagDirectory
- directory to save the DAG information.- Returns:
- optimized DAG, reshaped or tagged with execution properties.
-
runRunTimeOptimizations
public IRDAG runRunTimeOptimizations(IRDAG dag, Message<?> message)
Description copied from interface:Policy
Optimize the DAG with the run-time optimizations.- Specified by:
runRunTimeOptimizations
in interfacePolicy
- Parameters:
dag
- input DAG.message
- from the DAG execution.- Returns:
- optimized DAG, reshaped or tagged with execution properties.
-
-