Uses of Interface
org.apache.flink.autoscaler.JobAutoScaler
-
-
Uses of JobAutoScaler in org.apache.flink.autoscaler
Classes in org.apache.flink.autoscaler that implement JobAutoScaler Modifier and Type Class Description class
JobAutoScalerImpl<KEY,Context extends JobAutoScalerContext<KEY>>
The default implementation ofJobAutoScaler
.class
NoopJobAutoscaler<KEY,Context extends JobAutoScalerContext<KEY>>
An autoscaler implementation which does nothing. -
Uses of JobAutoScaler in org.apache.flink.autoscaler.standalone
Constructors in org.apache.flink.autoscaler.standalone with parameters of type JobAutoScaler Constructor Description StandaloneAutoscalerExecutor(org.apache.flink.configuration.Configuration conf, JobListFetcher<KEY,Context> jobListFetcher, AutoScalerEventHandler<KEY,Context> eventHandler, JobAutoScaler<KEY,Context> autoScaler)
-
Uses of JobAutoScaler in org.apache.flink.kubernetes.operator.autoscaler
Methods in org.apache.flink.kubernetes.operator.autoscaler that return JobAutoScaler Modifier and Type Method Description static JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>
AutoscalerFactory. create(io.fabric8.kubernetes.client.KubernetesClient client, EventRecorder eventRecorder, ClusterResourceManager clusterResourceManager)
-
Uses of JobAutoScaler in org.apache.flink.kubernetes.operator.reconciler.deployment
Fields in org.apache.flink.kubernetes.operator.reconciler.deployment declared as JobAutoScaler Modifier and Type Field Description protected JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>
AbstractFlinkResourceReconciler. autoscaler
-
Uses of JobAutoScaler in org.apache.flink.kubernetes.operator.reconciler.sessionjob
Constructors in org.apache.flink.kubernetes.operator.reconciler.sessionjob with parameters of type JobAutoScaler Constructor Description SessionJobReconciler(EventRecorder eventRecorder, StatusRecorder<FlinkSessionJob,FlinkSessionJobStatus> statusRecorder, JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
-