AutoScalerInfo |
Class for encapsulating information stored for each resource when using the autoscaler.
|
JobAutoscalerFactoryImpl |
Factory for loading JobAutoScalerImpl included in this module.
|
JobAutoScalerImpl |
Application and SessionJob autoscaler.
|
JobVertexScaler |
Component responsible for computing vertex parallelism based on the scaling metrics.
|
RestApiMetricsCollector |
Metric collector using flink rest api.
|
ScalingExecutor |
Class responsible for executing scaling decisions.
|
ScalingMetricCollector |
Metric collector using flink rest api.
|
ScalingMetricEvaluator |
Job scaling evaluator for autoscaler.
|
ScalingSummary |
|