Uses of Class
org.apache.storm.utils.LocalState

Packages that use LocalState

Package	Description
org.apache.storm.daemon.supervisor
org.apache.storm.utils

Uses of LocalState in org.apache.storm.daemon.supervisor

Fields in org.apache.storm.daemon.supervisor declared as LocalState

Modifier and Type	Field and Description
protected LocalState	BasicContainer._localState

Methods in org.apache.storm.daemon.supervisor with parameters of type LocalState

Modifier and Type	Method and Description
Container	RunAsUserContainerLauncher.launchContainer(int port, LocalAssignment assignment, LocalState state)
Container	LocalContainerLauncher.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	BasicContainerLauncher.launchContainer(int port, LocalAssignment assignment, LocalState state)
Container	RunAsUserContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state)
Container	LocalContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state)
abstract Container	ContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state) Recover a container for a running process
Container	BasicContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state)
Killable	RunAsUserContainerLauncher.recoverContainer(String workerId, LocalState localState)
Killable	LocalContainerLauncher.recoverContainer(String workerId, LocalState localState)
abstract Killable	ContainerLauncher.recoverContainer(String workerId, LocalState localState) Try to recover a container using just the worker ID. The result is really only useful for killing the container and so is returning a Killable.
Killable	BasicContainerLauncher.recoverContainer(String workerId, LocalState localState)

Constructors in org.apache.storm.daemon.supervisor with parameters of type LocalState

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.
RunAsUserContainer(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)
Slot(AsyncLocalizer localizer, Map<String,Object> conf, ContainerLauncher containerLauncher, String host, int port, LocalState localState, IStormClusterState clusterState, ISupervisor iSupervisor, 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

Methods in org.apache.storm.utils that return LocalState

Modifier and Type	Method and Description
static LocalState	ServerConfigUtils.nimbusTopoHistoryState(Map<String,Object> conf)
LocalState	ServerConfigUtils.nimbusTopoHistoryStateImpl(Map<String,Object> conf)
static LocalState	ServerConfigUtils.supervisorState(Map<String,Object> conf)
LocalState	ServerConfigUtils.supervisorStateImpl(Map<String,Object> conf)
static LocalState	ConfigUtils.workerState(Map<String,Object> conf, String id)