org.apache.storm.daemon.supervisor

## Class Slot

- java.lang.Object
- - java.lang.Thread
  - - org.apache.storm.daemon.supervisor.Slot

- All Implemented Interfaces:
    AutoCloseable, Runnable, BlobChangingCallback

      public class Slot
      extends Thread
      implements AutoCloseable, BlobChangingCallback

- - ### Nested Class Summary

    - ### Nested classes/interfaces inherited from class java.lang.Thread

      `Thread.State, Thread.UncaughtExceptionHandler`

  - ### Field Summary

    - ### Fields inherited from class java.lang.Thread

      `MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY`

  - ### Constructor Summary

    Constructors
    Constructor and Description
    `Slot(AsyncLocalizer localizer, Map<String,Object> conf, ContainerLauncher containerLauncher, String host, int port, LocalState localState, IStormClusterState clusterState, ISupervisor supervisor, AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments, OnlyLatestExecutor<Integer> metricsExec, WorkerMetricsProcessor metricsProcessor, org.apache.storm.daemon.supervisor.SlotMetrics slotMetrics)`

  - ### Method Summary

    All Methods Instance Methods Concrete Methods
    Modifier and Type | Method and Description
    --- | ---
    `void` | `addProfilerActions(Set<org.apache.storm.daemon.supervisor.Slot.TopoProfileAction> actions)`
    `void` | `blobChanging(LocalAssignment assignment, int port, LocallyCachedBlob blob, GoodToGo go)` Informs the listener that a blob has changed and is ready to update and replace a localized blob that has been marked as tied to the life cycle of the worker process.
    `void` | `close()`
    `String` | `getWorkerId()` get the workerID (nullable) from CURRENT container, if existed, or return null.
    `void` | `run()`
    `void` | `setNewAssignment(LocalAssignment newAssignment)` Set a new assignment asynchronously.

    - ### Methods inherited from class java.lang.Thread

      `activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield`

    - ### Methods inherited from class java.lang.Object

      `equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait`

- - ### Constructor Detail

    - #### Slot

          public Slot(AsyncLocalizer localizer,
                      Map<String,Object> conf,
                      ContainerLauncher containerLauncher,
                      String host,
                      int port,
                      LocalState localState,
                      IStormClusterState clusterState,
                      ISupervisor supervisor,
                      AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments,
                      OnlyLatestExecutor<Integer> metricsExec,
                      WorkerMetricsProcessor metricsProcessor,
                      org.apache.storm.daemon.supervisor.SlotMetrics slotMetrics)
               throws Exception

      Throws:
        `Exception`

  - ### Method Detail

    - #### setNewAssignment

          public final void setNewAssignment(LocalAssignment newAssignment)

      Set a new assignment asynchronously.

      Parameters:
        `newAssignment` - the new assignment for this slot to run, null to run nothing

    - #### blobChanging

          public void blobChanging(LocalAssignment assignment,
                                   int port,
                                   LocallyCachedBlob blob,
                                   GoodToGo go)

      Description copied from interface: `BlobChangingCallback`

      Informs the listener that a blob has changed and is ready to update and replace a localized blob that has been marked as tied to the life cycle of the worker process.

      If `go.getLatch()` is never called before the method completes it is assumed that the listener is good with the blob changing.

      Specified by:
        `blobChanging` in interface `BlobChangingCallback`
      Parameters:
        `assignment` - the assignment this resource and callback are registered with.
        `port` - the port that this resource and callback are registered with.
        `blob` - the blob that is going to change.
        `go` - a way to indicate if the listener is ready for the resource to change.

    - #### addProfilerActions

          public void addProfilerActions(Set<org.apache.storm.daemon.supervisor.Slot.TopoProfileAction> actions)

    - #### getWorkerId

          public String getWorkerId()

      get the workerID (nullable) from CURRENT container, if existed, or return null.

      Returns:
        workerID

    - #### run

          public void run()

      Specified by:
        `run` in interface `Runnable`
      Overrides:
        `run` in class `Thread`

    - #### close

          public void close()
                     throws Exception

      Specified by:
        `close` in interface `AutoCloseable`
      Throws:
        `Exception`

Copyright © 2021 The Apache Software Foundation. All rights reserved.