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 |
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) |
Constructor and Description |
---|
BasicContainer(Container.ContainerType type,
Map<String,Object> conf,
String supervisorId,
int port,
LocalAssignment assignment,
LocalState localState,
String workerId)
Create a new BasicContainer
|
RunAsUserContainer(Container.ContainerType type,
Map<String,Object> conf,
String supervisorId,
int port,
LocalAssignment assignment,
LocalState localState,
String workerId) |
Slot(ILocalizer localizer,
Map<String,Object> conf,
ContainerLauncher containerLauncher,
String host,
int port,
LocalState localState,
IStormClusterState clusterState,
ISupervisor iSupervisor,
AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments) |
Modifier and Type | Method and Description |
---|---|
static LocalState |
ConfigUtils.nimbusTopoHistoryState(Map conf) |
LocalState |
ConfigUtils.nimbusTopoHistoryStateImpl(Map conf) |
static LocalState |
ConfigUtils.supervisorState(Map conf) |
LocalState |
ConfigUtils.supervisorStateImpl(Map conf) |
static LocalState |
ConfigUtils.workerState(Map conf,
String id) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.