Package | Description |
---|---|
org.apache.storm.daemon.supervisor | |
org.apache.storm.utils |
Modifier and Type | Field and Description |
---|---|
protected LocalState |
BasicContainer.localState |
Modifier and Type | Method and Description |
---|---|
Container |
LocalContainerLauncher.launchContainer(int port,
LocalAssignment assignment,
LocalState state) |
Container |
RunAsUserContainerLauncher.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 |
RunAsUserContainerLauncher.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.
|
Killable |
LocalContainerLauncher.recoverContainer(String workerId,
LocalState localState) |
Killable |
RunAsUserContainerLauncher.recoverContainer(String workerId,
LocalState localState) |
Killable |
BasicContainerLauncher.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. |
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 supervisor,
AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments,
OnlyLatestExecutor<Integer> metricsExec,
WorkerMetricsProcessor metricsProcessor,
org.apache.storm.daemon.supervisor.SlotMetrics slotMetrics) |
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) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.