Package org.apache.nemo.compiler.optimizer.policy

Interface Summary

Interface	Description
Policy	An interface for policies, each of which is composed of a list of static optimization passes.

Class Summary

Class	Description
BasicPullPolicy	Basic pull policy.
BasicPushPolicy	Basic push policy.
ConditionalLargeShufflePolicy	A policy to demonstrate the large shuffle optimization, witch batches disk seek during data shuffle, conditionally.
DataSkewPolicy	A policy to perform data skew dynamic optimization.
DefaultPolicy	A basic default policy, that performs the minimum amount of optimization to be done to a specific DAG.
DefaultPolicyWithSeparatePass	A simple example policy to demonstrate a policy with a separate, refactored pass.
DefaultPolicyWithSeparatePass.RefactoredPass	A simple custom pass consisted of the two passes at the end of the default pass.
DisaggregationPolicy	A policy to demonstrate the disaggregation optimization, that uses GlusterFS as file storage.
DynamicTaskSizingPolicy	A policy to dynamically resize tasks in runtime.
LambdaPolicy	Lambda Policy Description: A part of lambda executor, to support Lambda policy.
LargeShufflePolicy	A policy to demonstrate the large shuffle optimization, witch batches disk seek during data shuffle.
PolicyBuilder	A builder for policies.
PolicyImpl	Implementation of the Policy interface.
SamplingLargeShuffleSkewPolicy	A policy to demonstrate the large shuffle optimization, witch batches disk seek during data shuffle.
StreamingPolicy	Streaming policy.
TestPolicy	A policy for tests.
TransientResourcePolicy	A policy to perform optimization that uses transient resources in data centers.
XGBoostPolicy	A policy that enforces values retrieved by an optimization by XGBoost.