Policy (Nemo Project 0.4 API)

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

BasicPullPolicy, BasicPushPolicy, ConditionalLargeShufflePolicy, DataSkewPolicy, DefaultPolicy, DefaultPolicyWithSeparatePass, DisaggregationPolicy, DynamicTaskSizingPolicy, LambdaPolicy, LargeShufflePolicy, PolicyImpl, SamplingLargeShuffleSkewPolicy, StreamingPolicy, TestPolicy, TransientResourcePolicy, XGBoostPolicy
```
public interface Policy
extends java.io.Serializable
```
An interface for policies, each of which is composed of a list of static optimization passes. The list of static optimization passes are run in the order provided by the implementation. Most policies follow the implementation in PolicyImpl.

Method Summary

All Methods Instance Methods Abstract 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.

- Method Detail
  - runCompileTimeOptimization
```
IRDAG runCompileTimeOptimization(IRDAG dag,
                                 java.lang.String dagDirectory)
```
    Optimize the DAG with the compile-time optimizations.
    
    Parameters:
    
    dag - input DAG.
    
    dagDirectory - directory to save the DAG information.
    
    Returns:
    
    optimized DAG, reshaped or tagged with execution properties.
  - runRunTimeOptimizations
```
IRDAG runRunTimeOptimizations(IRDAG dag,
                              Message<?> message)
```
    Optimize the DAG with the run-time optimizations.
    
    Parameters:
    
    dag - input DAG.
    
    message - from the DAG execution.
    
    Returns:
    
    optimized DAG, reshaped or tagged with execution properties.