File tree Expand file tree Collapse file tree
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/validation Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2020import org .apache .flink .annotation .VisibleForTesting ;
2121import org .apache .flink .autoscaler .JobAutoScaler ;
2222import org .apache .flink .autoscaler .JobAutoScalerContext ;
23- import static org .apache .flink .autoscaler .config .AutoScalerOptions .SCALING_EVENT_INTERVAL ;
2423import org .apache .flink .autoscaler .event .AutoScalerEventHandler ;
25- import static org .apache .flink .autoscaler .standalone .config .AutoscalerStandaloneOptions .CONTROL_LOOP_INTERVAL ;
26- import static org .apache .flink .autoscaler .standalone .config .AutoscalerStandaloneOptions .CONTROL_LOOP_PARALLELISM ;
2724import org .apache .flink .autoscaler .validation .AutoscalerValidator ;
2825import org .apache .flink .configuration .Configuration ;
2926import org .apache .flink .configuration .UnmodifiableConfiguration ;
5552import java .util .function .Function ;
5653import java .util .stream .Collectors ;
5754
55+ import static org .apache .flink .autoscaler .config .AutoScalerOptions .SCALING_EVENT_INTERVAL ;
56+ import static org .apache .flink .autoscaler .standalone .config .AutoscalerStandaloneOptions .CONTROL_LOOP_INTERVAL ;
57+ import static org .apache .flink .autoscaler .standalone .config .AutoscalerStandaloneOptions .CONTROL_LOOP_PARALLELISM ;
58+
5859/** The executor of the standalone autoscaler. */
5960public class StandaloneAutoscalerExecutor <KEY , Context extends JobAutoScalerContext <KEY >>
6061 implements AutoCloseable {
Original file line number Diff line number Diff line change 1919package org .apache .flink .autoscaler .validation ;
2020
2121import org .apache .flink .autoscaler .config .AutoScalerOptions ;
22- import static org .apache .flink .autoscaler .config .AutoScalerOptions .OBSERVED_SCALABILITY_COEFFICIENT_MIN ;
23- import static org .apache .flink .autoscaler .config .AutoScalerOptions .UTILIZATION_MAX ;
24- import static org .apache .flink .autoscaler .config .AutoScalerOptions .UTILIZATION_MIN ;
25- import static org .apache .flink .autoscaler .config .AutoScalerOptions .UTILIZATION_TARGET ;
2622import org .apache .flink .autoscaler .utils .CalendarUtils ;
2723import org .apache .flink .configuration .ConfigOption ;
2824import org .apache .flink .configuration .Configuration ;
2925
3026import java .util .Optional ;
3127
28+ import static org .apache .flink .autoscaler .config .AutoScalerOptions .OBSERVED_SCALABILITY_COEFFICIENT_MIN ;
29+ import static org .apache .flink .autoscaler .config .AutoScalerOptions .UTILIZATION_MAX ;
30+ import static org .apache .flink .autoscaler .config .AutoScalerOptions .UTILIZATION_MIN ;
31+ import static org .apache .flink .autoscaler .config .AutoScalerOptions .UTILIZATION_TARGET ;
32+
3233/** Validator for Autoscaler. */
3334public class AutoscalerValidator {
3435
You can’t perform that action at this time.
0 commit comments