Package org.apache.hadoop.yarn.server.globalpolicygenerator.subclustercleaner

Class SubClusterCleaner

java.lang.Object
org.apache.hadoop.yarn.server.globalpolicygenerator.subclustercleaner.SubClusterCleaner
All Implemented Interfaces:
Runnable
public class SubClusterCleaner extends Object implements Runnable
The sub-cluster cleaner is one of the GPG's services that periodically checks the membership table in FederationStateStore and mark sub-clusters that have not sent a heartbeat in certain amount of time as LOST.

  • Constructor Summary

    Constructors
    Constructor
    Description
    SubClusterCleaner(org.apache.hadoop.conf.Configuration conf, GPGContext gpgContext)
    The sub-cluster cleaner runnable is invoked by the sub cluster cleaner service to check the membership table and remove sub clusters that have not sent a heart beat in some amount of time.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    run()
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • SubClusterCleaner

      public SubClusterCleaner(org.apache.hadoop.conf.Configuration conf, GPGContext gpgContext)
      The sub-cluster cleaner runnable is invoked by the sub cluster cleaner service to check the membership table and remove sub clusters that have not sent a heart beat in some amount of time.
      Parameters:
      conf - configuration.
      gpgContext - GPGContext.

  • Method Details

    • run

      public void run()
      Specified by:
      run in interface Runnable