Uses of Class
org.apache.storm.utils.LocalState
-
Uses of LocalState in org.apache.storm.daemon.supervisor
Modifier and TypeMethodDescriptionBasicContainerLauncher.launchContainer
(int port, LocalAssignment assignment, LocalState state) abstract Container
ContainerLauncher.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) BasicContainerLauncher.recoverContainer
(String workerId, LocalState localState) abstract Container
ContainerLauncher.recoverContainer
(int port, LocalAssignment assignment, LocalState state) Recover a container for a running process.abstract Killable
ContainerLauncher.recoverContainer
(String workerId, LocalState localState) Try to recover a container using just the worker ID.LocalContainerLauncher.recoverContainer
(int port, LocalAssignment assignment, LocalState state) LocalContainerLauncher.recoverContainer
(String workerId, LocalState localState) ModifierConstructorDescriptionBasicContainer
(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.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 LocalState in org.apache.storm.utils
Modifier and TypeMethodDescriptionstatic LocalState
ServerConfigUtils.nimbusTopoHistoryState
(Map<String, Object> conf) ServerConfigUtils.nimbusTopoHistoryStateImpl
(Map<String, Object> conf) static LocalState
ServerConfigUtils.supervisorState
(Map<String, Object> conf) ServerConfigUtils.supervisorStateImpl
(Map<String, Object> conf) static LocalState
ConfigUtils.workerState
(Map<String, Object> conf, String id)