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 © 2019 The Apache Software Foundation. All Rights Reserved.