Package org.apache.storm.daemon.supervisor

Class SupervisorUtils

java.lang.Object
org.apache.storm.daemon.supervisor.SupervisorUtils
public class SupervisorUtils extends Object

  • Constructor Details

    • SupervisorUtils

      public SupervisorUtils()

  • Method Details

    • setInstance

      public static void setInstance(SupervisorUtils u)

    • resetInstance

      public static void resetInstance()

    • getNumaIdForPort

      public static String getNumaIdForPort(Integer port, Map<String,Object> supervisorConf)
      getNumaIdForPort for a specific supervisor.
      Parameters:
      port - port
      supervisorConf - supervisorConf
      Returns:
      getNumaIdForPort

    • getNumaPorts

      public static Set<Integer> getNumaPorts(Map<String,Object> supervisorConf)
      gets the set of all configured numa ports for a specific supervisor.
      Parameters:
      supervisorConf - supervisorConf
      Returns:
      set of all numa ports

    • getSlotsPorts

      public static List<Integer> getSlotsPorts(Map<String,Object> supervisorConf)

    • rmrAsUser

      public static void rmrAsUser(Map<String,Object> conf, String id, String path) throws IOException
      Throws:
      IOException

    • shouldUncompressBlob

      public static boolean shouldUncompressBlob(Map<String,Object> blobInfo)
      Given the blob information returns the value of the uncompress field, handling it being a boolean value, or if it's not specified then returns false.

    • blobNeedsWorkerRestart

      public static boolean blobNeedsWorkerRestart(Map<String,Object> blobInfo)
      Given the blob information returns the value of the workerRestart field, handling it being a boolean value, or if it's not specified then returns false.
      Parameters:
      blobInfo - the info for the blob.
      Returns:
      true if the blob needs a worker restart by way of the callback else false.

    • blobstoreMapToLocalresources

      public static List<LocalResource> blobstoreMapToLocalresources(Map<String,Map<String,Object>> blobstoreMap)
      Returns a list of LocalResources based on the blobstore-map passed in.

    • supervisorWorkerIds

      public static Collection<String> supervisorWorkerIds(Map<String,Object> conf)

    • readWorkerHeartbeats

      public static Map<String,LSWorkerHeartbeat> readWorkerHeartbeats(Map<String,Object> conf)
      Map from worker id to heartbeat.

    • getNumaMap

      public static Map<String,Object> getNumaMap(Map<String,Object> stormConf)
      Return supervisor numa configuration.
      Parameters:
      stormConf - stormConf
      Returns:
      getNumaMap

    • readWorkerHeartbeatsImpl

      public Map<String,LSWorkerHeartbeat> readWorkerHeartbeatsImpl(Map<String,Object> conf)

    • readWorkerHeartbeatImpl

      protected LSWorkerHeartbeat readWorkerHeartbeatImpl(Map<String,Object> conf, String workerId)