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

Class KubernetesJobAutoScalerContext

java.lang.Object

org.apache.flink.autoscaler.JobAutoScalerContext<io.javaoperatorsdk.operator.processing.event.ResourceID>

org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext

public class KubernetesJobAutoScalerContext
extends 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, AbstractFlinkResource<?,?> resource, io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)

Method Summary

Modifier and Type	Method	Description
io.fabric8.kubernetes.client.KubernetesClient	getKubernetesClient()
AbstractFlinkResource<?,?>	getResource()

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

getRestClusterClient

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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,
                                      AbstractFlinkResource<?,?> resource,
                                      io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)

Method Detail

getResource

public AbstractFlinkResource<?,?> getResource()

getKubernetesClient

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