Package org.apache.flink.autoscaler

Class JobAutoScalerContext<KEY>

  • Type Parameters:
    KEY - The job key.
    Direct Known Subclasses:
    KubernetesJobAutoScalerContext
    @Experimental
public class JobAutoScalerContext<KEY>
extends java.lang.Object
    The job autoscaler context, it includes all details related to the current job.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.flink.client.program.rest.RestClusterClient<java.lang.String> getRestClusterClient()  
      java.util.Optional<java.lang.Double> getTaskManagerCpu()
      Retrieve the currently configured TaskManager CPU.
      java.util.Optional<org.apache.flink.configuration.MemorySize> getTaskManagerMemory()
      Retrieve the currently configured TaskManager memory.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • JobAutoScalerContext

        public JobAutoScalerContext()

    • Method Detail

      • getTaskManagerCpu

        public java.util.Optional<java.lang.Double> getTaskManagerCpu()
        Retrieve the currently configured TaskManager CPU.

      • getTaskManagerMemory

        public java.util.Optional<org.apache.flink.configuration.MemorySize> getTaskManagerMemory()
        Retrieve the currently configured TaskManager memory.

      • getRestClusterClient

        public org.apache.flink.client.program.rest.RestClusterClient<java.lang.String> getRestClusterClient()
                                                                                              throws java.lang.Exception
        Throws:
        java.lang.Exception