| Package | Description |
|---|---|
| org.apache.storm.cluster | |
| org.apache.storm.daemon.supervisor |
| Modifier and Type | Class and Description |
|---|---|
class |
StormClusterStateImpl |
| Modifier and Type | Method and Description |
|---|---|
static IStormClusterState |
ClusterUtils.mkStormClusterState(Object StateStorage,
List<org.apache.zookeeper.data.ACL> acls,
ClusterStateContext context) |
IStormClusterState |
ClusterUtils.mkStormClusterStateImpl(Object stateStorage,
List<org.apache.zookeeper.data.ACL> acls,
ClusterStateContext context) |
| Modifier and Type | Method and Description |
|---|---|
IStormClusterState |
Supervisor.getStormClusterState() |
| Modifier and Type | Method and Description |
|---|---|
protected Map<String,VersionedData<Assignment>> |
ReadClusterState.getAssignmentsSnapshot(IStormClusterState stormClusterState,
List<String> topoIds,
Map<String,VersionedData<Assignment>> localAssignmentVersion,
Runnable callback) |
protected Map<String,List<ProfileRequest>> |
ReadClusterState.getProfileActions(IStormClusterState stormClusterState,
List<String> stormIds) |
| Constructor and Description |
|---|
Slot(ILocalizer localizer,
Map<String,Object> conf,
ContainerLauncher containerLauncher,
String host,
int port,
LocalState localState,
IStormClusterState clusterState,
ISupervisor iSupervisor,
AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.