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 Description protected LocalState
BasicContainer. localState
Methods in org.apache.storm.daemon.supervisor with parameters of type LocalState Modifier and Type Method Description 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. launchContainer(int port, LocalAssignment assignment, LocalState state)
Container
BasicContainerLauncher. recoverContainer(int port, LocalAssignment assignment, LocalState state)
Killable
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.Container
LocalContainerLauncher. recoverContainer(int port, LocalAssignment assignment, LocalState state)
Killable
LocalContainerLauncher. recoverContainer(String workerId, LocalState localState)
Constructors in org.apache.storm.daemon.supervisor with parameters of type LocalState Constructor 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.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
Methods in org.apache.storm.utils that return LocalState Modifier and Type Method 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)
-