Package org.apache.flink.kubernetes.operator.autoscaler

Class KubernetesJobAutoScalerContext

  • public class KubernetesJobAutoScalerContext
extends org.apache.flink.autoscaler.JobAutoScalerContext<io.javaoperatorsdk.operator.processing.event.ResourceID>
    An implementation of JobAutoscalerContext for Kubernetes.

    • Constructor Summary

      Constructors 
      Constructor Description
      KubernetesJobAutoScalerContext​(org.apache.flink.api.common.JobID jobID, org.apache.flink.api.common.JobStatus jobStatus, org.apache.flink.configuration.Configuration configuration, org.apache.flink.metrics.MetricGroup metricGroup, org.apache.flink.util.function.SupplierWithException<org.apache.flink.client.program.rest.RestClusterClient<java.lang.String>,​java.lang.Exception> restClientSupplier, org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,​?> resource, io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      io.fabric8.kubernetes.client.KubernetesClient getKubernetesClient()  
      org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,​?> getResource()  

      • Methods inherited from class org.apache.flink.autoscaler.JobAutoScalerContext

        getConfiguration, getJobID, getJobKey, getJobStatus, getMetricGroup, getRestClusterClient, toString

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    • Constructor Detail

      • KubernetesJobAutoScalerContext

        public KubernetesJobAutoScalerContext​(@Nullable
                                      org.apache.flink.api.common.JobID jobID,
                                      @Nullable
                                      org.apache.flink.api.common.JobStatus jobStatus,
                                      org.apache.flink.configuration.Configuration configuration,
                                      org.apache.flink.metrics.MetricGroup metricGroup,
                                      org.apache.flink.util.function.SupplierWithException<org.apache.flink.client.program.rest.RestClusterClient<java.lang.String>,​java.lang.Exception> restClientSupplier,
                                      org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,​?> resource,
                                      io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)

    • Method Detail

      • getResource

        public org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,​?> getResource()

      • getKubernetesClient

        public io.fabric8.kubernetes.client.KubernetesClient getKubernetesClient()