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, FlinkResourceContext<?> resourceContext)

Method Summary

Modifier and Type	Method	Description
io.fabric8.kubernetes.client.KubernetesClient	getKubernetesClient()
AbstractFlinkResource<?,?>	getResource()
java.util.Optional<java.lang.Double>	getTaskManagerCpu()	Retrieve the currently configured TaskManager CPU.

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

getRestClusterClient, getTaskManagerMemory

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,
                                      FlinkResourceContext<?> resourceContext)

Method Detail

getTaskManagerCpu

public java.util.Optional<java.lang.Double> getTaskManagerCpu()

Description copied from class: JobAutoScalerContext

Retrieve the currently configured TaskManager CPU.

Overrides:

getTaskManagerCpu in class JobAutoScalerContext<io.javaoperatorsdk.operator.processing.event.ResourceID>

getResource

public AbstractFlinkResource<?,?> getResource()

getKubernetesClient

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