| Package | Description | 
|---|---|
| org.apache.storm.cluster | |
| org.apache.storm.daemon.worker | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
PaceMakerStateStorage  | 
class  | 
ZKStateStorage  | 
| Modifier and Type | Method and Description | 
|---|---|
static IStateStorage | 
ClusterUtils.mkStateStorage(Map<String,Object> config,
              Map<String,Object> authConf,
              ClusterStateContext context)  | 
IStateStorage | 
ClusterUtils.mkStateStorageImpl(Map<String,Object> config,
                  Map<String,Object> authConf,
                  ClusterStateContext context)  | 
IStateStorage | 
ZKStateStorageFactory.mkStore(Map<String,Object> config,
       Map<String,Object> authConf,
       ClusterStateContext context)  | 
IStateStorage | 
PaceMakerStateStorageFactory.mkStore(Map<String,Object> config,
       Map<String,Object> authConf,
       ClusterStateContext context)  | 
IStateStorage | 
StateStorageFactory.mkStore(Map<String,Object> config,
       Map<String,Object> authConf,
       ClusterStateContext context)  | 
| Constructor and Description | 
|---|
PaceMakerStateStorage(PacemakerClientPool pacemakerClientPool,
                     IStateStorage stateStorage)  | 
StormClusterStateImpl(IStateStorage stateStorage,
                     ILocalAssignmentsBackend assignmentsassignmentsBackend,
                     ClusterStateContext context,
                     boolean shouldCloseStateStorageOnDisconnect)  | 
| Modifier and Type | Method and Description | 
|---|---|
IStateStorage | 
WorkerState.getStateStorage()  | 
| Constructor and Description | 
|---|
WorkerState(Map<String,Object> conf,
           IContext mqContext,
           String topologyId,
           String assignmentId,
           Supplier<SupervisorIfaceFactory> supervisorIfaceSupplier,
           int port,
           String workerId,
           Map<String,Object> topologyConf,
           IStateStorage stateStorage,
           IStormClusterState stormClusterState,
           Collection<IAutoCredentials> autoCredentials,
           StormMetricRegistry metricRegistry,
           Credentials initialCredentials)  | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.