Class NoopResourceCheck

  • All Implemented Interfaces:
    ResourceCheck

    public class NoopResourceCheck
    extends java.lang.Object
    implements ResourceCheck
    Noop implementation for checking for available resources.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean trySchedule​(int currentInstances, int newInstances, double numCpu, org.apache.flink.configuration.MemorySize numMemory)
      Simulates scheduling the provided number of TaskManager instances.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • NoopResourceCheck

        public NoopResourceCheck()
    • Method Detail

      • trySchedule

        public boolean trySchedule​(int currentInstances,
                                   int newInstances,
                                   double numCpu,
                                   org.apache.flink.configuration.MemorySize numMemory)
        Description copied from interface: ResourceCheck
        Simulates scheduling the provided number of TaskManager instances.
        Specified by:
        trySchedule in interface ResourceCheck
        Parameters:
        currentInstances - The current number of instances.
        newInstances - The new number of instances.
        numCpu - The number of CPU per instances.
        numMemory - The total memory size per instances.
        Returns:
        true if a scheduling configuration was found, false otherwise.