pub struct SparkStandaloneAutoscalingConfig {
pub graceful_decommission_timeout: Option<Duration>,
pub remove_only_idle_workers: Option<bool>,
pub scale_down_factor: Option<f64>,
pub scale_down_min_worker_fraction: Option<f64>,
pub scale_up_factor: Option<f64>,
pub scale_up_min_worker_fraction: Option<f64>,
}
Expand description
Basic autoscaling configurations for Spark Standalone.
This type is not used in any activity, and only used as part of another schema.
Fields§
§graceful_decommission_timeout: Option<Duration>
Required. Timeout for Spark graceful decommissioning of spark workers. Specifies the duration to wait for spark worker to complete spark decommissioning tasks before forcefully removing workers. Only applicable to downscaling operations.Bounds: 0s, 1d.
remove_only_idle_workers: Option<bool>
Optional. Remove only idle workers when scaling down cluster
scale_down_factor: Option<f64>
Required. Fraction of required executors to remove from Spark Serverless clusters. A scale-down factor of 1.0 will result in scaling down so that there are no more executors for the Spark Job.(more aggressive scaling). A scale-down factor closer to 0 will result in a smaller magnitude of scaling donw (less aggressive scaling).Bounds: 0.0, 1.0.
scale_down_min_worker_fraction: Option<f64>
Optional. Minimum scale-down threshold as a fraction of total cluster size before scaling occurs. For example, in a 20-worker cluster, a threshold of 0.1 means the autoscaler must recommend at least a 2 worker scale-down for the cluster to scale. A threshold of 0 means the autoscaler will scale down on any recommended change.Bounds: 0.0, 1.0. Default: 0.0.
scale_up_factor: Option<f64>
Required. Fraction of required workers to add to Spark Standalone clusters. A scale-up factor of 1.0 will result in scaling up so that there are no more required workers for the Spark Job (more aggressive scaling). A scale-up factor closer to 0 will result in a smaller magnitude of scaling up (less aggressive scaling).Bounds: 0.0, 1.0.
scale_up_min_worker_fraction: Option<f64>
Optional. Minimum scale-up threshold as a fraction of total cluster size before scaling occurs. For example, in a 20-worker cluster, a threshold of 0.1 means the autoscaler must recommend at least a 2-worker scale-up for the cluster to scale. A threshold of 0 means the autoscaler will scale up on any recommended change.Bounds: 0.0, 1.0. Default: 0.0.
Trait Implementations§
Source§impl Clone for SparkStandaloneAutoscalingConfig
impl Clone for SparkStandaloneAutoscalingConfig
Source§fn clone(&self) -> SparkStandaloneAutoscalingConfig
fn clone(&self) -> SparkStandaloneAutoscalingConfig
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Default for SparkStandaloneAutoscalingConfig
impl Default for SparkStandaloneAutoscalingConfig
Source§fn default() -> SparkStandaloneAutoscalingConfig
fn default() -> SparkStandaloneAutoscalingConfig
Source§impl<'de> Deserialize<'de> for SparkStandaloneAutoscalingConfig
impl<'de> Deserialize<'de> for SparkStandaloneAutoscalingConfig
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
impl Part for SparkStandaloneAutoscalingConfig
Auto Trait Implementations§
impl Freeze for SparkStandaloneAutoscalingConfig
impl RefUnwindSafe for SparkStandaloneAutoscalingConfig
impl Send for SparkStandaloneAutoscalingConfig
impl Sync for SparkStandaloneAutoscalingConfig
impl Unpin for SparkStandaloneAutoscalingConfig
impl UnwindSafe for SparkStandaloneAutoscalingConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more