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