## Uses of Class
org.apache.storm.generated.LocalAssignment

- Packages that use LocalAssignment
  Package | Description
  --- | ---
  org.apache.storm.daemon.supervisor |
  org.apache.storm.generated |
  org.apache.storm.localizer |
  org.apache.storm.utils |

- - ### Uses of LocalAssignment in org.apache.storm.daemon.supervisor

    Subclasses of LocalAssignment in org.apache.storm.daemon.supervisor
    Modifier and Type | Class and Description
    --- | ---
    `class` | `TimerDecoratedAssignment`

    Fields in org.apache.storm.daemon.supervisor declared as LocalAssignment
    Modifier and Type | Field and Description
    --- | ---
    `protected LocalAssignment` | Container.`assignment`

    Methods in org.apache.storm.daemon.supervisor that return types with arguments of type LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `AtomicReference<Map<Long,LocalAssignment>>` | Supervisor.`getCurrAssignment()`
    `protected Map<Integer,LocalAssignment>` | ReadClusterState.`readAssignments(Map<String,Assignment> assignmentsSnapshot)`
    `protected Map<Integer,LocalAssignment>` | ReadClusterState.`readMyExecutors(String topoId, String assignmentId, Assignment assignment)`

    Methods in org.apache.storm.daemon.supervisor with parameters of type LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `void` | Slot.`blobChanging(LocalAssignment assignment, int port, LocallyCachedBlob blob, GoodToGo go)`
    `long` | Container.`getTotalTopologyMemoryReserved(LocalAssignment withUpdatedLimits)` Get the total memory reserved.
    `boolean` | BasicContainer.`isMemoryLimitViolated(LocalAssignment withUpdatedLimits)`
    `boolean` | Container.`isMemoryLimitViolated(LocalAssignment withUpdatedLimits)` Check if the container is over its memory limit AND needs to be killed.
    `Container` | LocalContainerLauncher.`launchContainer(int port, LocalAssignment assignment, LocalState state)`
    `Container` | BasicContainerLauncher.`launchContainer(int port, LocalAssignment assignment, LocalState state)`
    `abstract Container` | ContainerLauncher.`launchContainer(int port, LocalAssignment assignment, LocalState state)` Launch a container in a given slot.
    `Container` | LocalContainerLauncher.`recoverContainer(int port, LocalAssignment assignment, LocalState state)`
    `Container` | BasicContainerLauncher.`recoverContainer(int port, LocalAssignment assignment, LocalState state)`
    `abstract Container` | ContainerLauncher.`recoverContainer(int port, LocalAssignment assignment, LocalState state)` Recover a container for a running process.
    `void` | Slot.`setNewAssignment(LocalAssignment newAssignment)` Set a new assignment asynchronously.

    Constructors in org.apache.storm.daemon.supervisor with parameters of type LocalAssignment
    Constructor and Description
    `BasicContainer(Container.ContainerType type, Map<String,Object> conf, String supervisorId, int supervisorPort, int port, LocalAssignment assignment, ResourceIsolationInterface resourceIsolationManager, LocalState localState, String workerId, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker)` Create a new BasicContainer.
    `Container(Container.ContainerType type, Map<String,Object> conf, String supervisorId, int supervisorPort, int port, LocalAssignment assignment, ResourceIsolationInterface resourceIsolationManager, String workerId, Map<String,Object> topoConf, AdvancedFSOps ops, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker)` Create a new Container.
    `LocalContainer(Map<String,Object> conf, String supervisorId, int supervisorPort, int port, LocalAssignment assignment, IContext sharedContext, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker, Supervisor.Iface localSupervisor)`
    `TimerDecoratedAssignment(LocalAssignment other, com.codahale.metrics.Timer timer)`

    Constructor parameters in org.apache.storm.daemon.supervisor with type arguments of type LocalAssignment
    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)`

  - ### Uses of LocalAssignment in org.apache.storm.generated

    Methods in org.apache.storm.generated that return LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `LocalAssignment` | LocalAssignment.`deepCopy()`

    Methods in org.apache.storm.generated that return types with arguments of type LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `Map<Integer,LocalAssignment>` | LSSupervisorAssignments.`get_assignments()`

    Methods in org.apache.storm.generated with parameters of type LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `int` | LocalAssignment.`compareTo(LocalAssignment other)`
    `boolean` | LocalAssignment.`equals(LocalAssignment that)`
    `void` | LSSupervisorAssignments.`put_to_assignments(int key, LocalAssignment val)`

    Method parameters in org.apache.storm.generated with type arguments of type LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `void` | LSSupervisorAssignments.`set_assignments(Map<Integer,LocalAssignment> assignments)`

    Constructors in org.apache.storm.generated with parameters of type LocalAssignment
    Constructor and Description
    `LocalAssignment(LocalAssignment other)` Performs a deep copy on other.

    Constructor parameters in org.apache.storm.generated with type arguments of type LocalAssignment
    Constructor and Description
    `LSSupervisorAssignments(Map<Integer,LocalAssignment> assignments)`

  - ### Uses of LocalAssignment in org.apache.storm.localizer

    Methods in org.apache.storm.localizer that return LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `LocalAssignment` | TimePortAndAssignment.`getAssignment()`
    `LocalAssignment` | PortAndAssignment.`getAssignment()`

    Methods in org.apache.storm.localizer with parameters of type LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `void` | BlobChangingCallback.`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` | AsyncLocalizer.`recoverRunningTopology(LocalAssignment currentAssignment, int port, BlobChangingCallback cb)` Do everything needed to recover the state in the AsyncLocalizer for a running topology.
    `void` | AsyncLocalizer.`releaseSlotFor(LocalAssignment assignment, int port)` Remove this assignment/port as blocking resources from being cleaned up.
    `CompletableFuture<Void>` | AsyncLocalizer.`requestDownloadTopologyBlobs(LocalAssignment assignment, int port, BlobChangingCallback cb)` Request that all of the blobs necessary for this topology be downloaded.

  - ### Uses of LocalAssignment in org.apache.storm.utils

    Methods in org.apache.storm.utils that return types with arguments of type LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `Map<Integer,LocalAssignment>` | LocalState.`getLocalAssignmentsMap()`

    Methods in org.apache.storm.utils with parameters of type LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `static boolean` | EquivalenceUtils.`areLocalAssignmentsEquivalent(LocalAssignment first, LocalAssignment second)` Decide the equivalence of two local assignments, ignoring the order of executors This is different from #equal method.

    Method parameters in org.apache.storm.utils with type arguments of type LocalAssignment
    Modifier and Type | Method and Description
    --- | ---
    `void` | LocalState.`setLocalAssignmentsMap(Map<Integer,LocalAssignment> localAssignmentMap)`

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