Class DataSkewPolicy
- java.lang.Object
-
- org.apache.nemo.compiler.optimizer.policy.DataSkewPolicy
-
- All Implemented Interfaces:
java.io.Serializable
,Policy
public final class DataSkewPolicy extends java.lang.Object implements Policy
A policy to perform data skew dynamic optimization.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static PolicyBuilder
BUILDER
-
Constructor Summary
Constructors Constructor Description DataSkewPolicy()
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.
-
-