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)