Uses of Class
org.apache.storm.generated.LocalAssignment
Packages that use LocalAssignment
Package
Description
-
Uses of LocalAssignment in org.apache.storm.daemon.supervisor
Subclasses of LocalAssignment in org.apache.storm.daemon.supervisorFields in org.apache.storm.daemon.supervisor declared as LocalAssignmentMethods in org.apache.storm.daemon.supervisor that return types with arguments of type LocalAssignmentModifier and TypeMethodDescriptionSupervisor.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 LocalAssignmentModifier and TypeMethodDescriptionvoidSlot.blobChanging(LocalAssignment assignment, int port, LocallyCachedBlob blob, GoodToGo go) longContainer.getTotalTopologyMemoryReserved(LocalAssignment withUpdatedLimits) Get the total memory reserved.booleanBasicContainer.isMemoryLimitViolated(LocalAssignment withUpdatedLimits) booleanContainer.isMemoryLimitViolated(LocalAssignment withUpdatedLimits) Check if the container is over its memory limit AND needs to be killed.BasicContainerLauncher.launchContainer(int port, LocalAssignment assignment, LocalState state) abstract ContainerContainerLauncher.launchContainer(int port, LocalAssignment assignment, LocalState state) Launch a container in a given slot.LocalContainerLauncher.launchContainer(int port, LocalAssignment assignment, LocalState state) BasicContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state) abstract ContainerContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state) Recover a container for a running process.LocalContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state) final voidSlot.setNewAssignment(LocalAssignment newAssignment) Set a new assignment asynchronously.Constructors in org.apache.storm.daemon.supervisor with parameters of type LocalAssignmentModifierConstructorDescriptionBasicContainer(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.protectedContainer(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 LocalAssignmentModifierConstructorDescriptionSlot(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 LocalAssignmentMethods in org.apache.storm.generated that return types with arguments of type LocalAssignmentMethods in org.apache.storm.generated with parameters of type LocalAssignmentModifier and TypeMethodDescriptionintLocalAssignment.compareTo(LocalAssignment other) booleanLocalAssignment.equals(LocalAssignment that) voidLSSupervisorAssignments.put_to_assignments(int key, LocalAssignment val) Method parameters in org.apache.storm.generated with type arguments of type LocalAssignmentModifier and TypeMethodDescriptionvoidLSSupervisorAssignments.set_assignments(Map<Integer, LocalAssignment> assignments) Constructors in org.apache.storm.generated with parameters of type LocalAssignmentModifierConstructorDescriptionLocalAssignment(LocalAssignment other) Performs a deep copy on other.Constructor parameters in org.apache.storm.generated with type arguments of type LocalAssignment -
Uses of LocalAssignment in org.apache.storm.localizer
Methods in org.apache.storm.localizer that return LocalAssignmentModifier and TypeMethodDescriptionPortAndAssignment.getAssignment()TimePortAndAssignment.getAssignment()Methods in org.apache.storm.localizer with parameters of type LocalAssignmentModifier and TypeMethodDescriptionvoidBlobChangingCallback.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.voidAsyncLocalizer.recoverRunningTopology(LocalAssignment currentAssignment, int port, BlobChangingCallback cb) Do everything needed to recover the state in the AsyncLocalizer for a running topology.voidAsyncLocalizer.releaseSlotFor(LocalAssignment assignment, int port) Remove this assignment/port as blocking resources from being cleaned up.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 LocalAssignmentMethods in org.apache.storm.utils with parameters of type LocalAssignmentModifier and TypeMethodDescriptionstatic booleanEquivalenceUtils.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 LocalAssignmentModifier and TypeMethodDescriptionvoidLocalState.setLocalAssignmentsMap(Map<Integer, LocalAssignment> localAssignmentMap)