Uses of Class
org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
-
Packages that use AutoScalerInfo Package Description org.apache.flink.kubernetes.operator.autoscaler -
-
Uses of AutoScalerInfo in org.apache.flink.kubernetes.operator.autoscaler
Methods in org.apache.flink.kubernetes.operator.autoscaler that return AutoScalerInfo Modifier and Type Method Description AutoScalerInfo
AutoscalerInfoManager. getOrCreateInfo(AbstractFlinkResource<?,?> cr, io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)
Methods in org.apache.flink.kubernetes.operator.autoscaler that return types with arguments of type AutoScalerInfo Modifier and Type Method Description java.util.Optional<AutoScalerInfo>
AutoscalerInfoManager. getInfo(AbstractFlinkResource<?,?> cr, io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)
Methods in org.apache.flink.kubernetes.operator.autoscaler with parameters of type AutoScalerInfo Modifier and Type Method Description protected JobTopology
ScalingMetricCollector. getJobTopology(FlinkService flinkService, org.apache.flink.configuration.Configuration conf, AutoScalerInfo scalerInfo, org.apache.flink.runtime.rest.messages.job.JobDetailsInfo jobDetailsInfo)
boolean
ScalingExecutor. scaleResource(AbstractFlinkResource<?,?> resource, AutoScalerInfo scalingInformation, org.apache.flink.configuration.Configuration conf, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>> evaluatedMetrics, io.fabric8.kubernetes.client.KubernetesClient client)
CollectedMetricHistory
ScalingMetricCollector. updateMetrics(AbstractFlinkResource<?,?> cr, AutoScalerInfo autoscalerInfo, FlinkService flinkService, org.apache.flink.configuration.Configuration conf)
-