Package org.apache.flink.autoscaler

Interface Summary

Interface	Description
JobAutoScaler<KEY,Context extends JobAutoScalerContext<KEY>>	Flink Job AutoScaler.

Class Summary

Class	Description
JobAutoScalerContext<KEY>	The job autoscaler context, it includes all details related to the current job.
JobAutoScalerImpl<KEY,Context extends JobAutoScalerContext<KEY>>	The default implementation of JobAutoScaler.
JobVertexScaler<KEY,Context extends JobAutoScalerContext<KEY>>	Component responsible for computing vertex parallelism based on the scaling metrics.
NoopJobAutoscaler<KEY,Context extends JobAutoScalerContext<KEY>>	An autoscaler implementation which does nothing.
RestApiMetricsCollector<KEY,Context extends JobAutoScalerContext<KEY>>	Metric collector using flink rest api.
ScalingExecutor<KEY,Context extends JobAutoScalerContext<KEY>>	Class responsible for executing scaling decisions.
ScalingMetricCollector<KEY,Context extends JobAutoScalerContext<KEY>>	Metric collector using flink rest api.
ScalingMetricEvaluator	Job scaling evaluator for autoscaler.
ScalingRecord	Class for tracking scaling details, including time it took for the job to transition to the target parallelism.
ScalingSummary	Scaling summary returned by the ScalingMetricEvaluator.
ScalingTracking	Stores rescaling related information for the job.