Uses of Interface
org.apache.storm.cluster.IStateStorage
-
Packages that use IStateStorage Package Description org.apache.storm.cluster org.apache.storm.daemon.worker -
-
Uses of IStateStorage in org.apache.storm.cluster
Classes in org.apache.storm.cluster that implement IStateStorage Modifier and Type Class Description class
PaceMakerStateStorage
class
ZKStateStorage
Methods in org.apache.storm.cluster that return IStateStorage Modifier and Type Method 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
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)
IStateStorage
ZKStateStorageFactory. mkStore(Map<String,Object> config, Map<String,Object> authConf, ClusterStateContext context)
Constructors in org.apache.storm.cluster with parameters of type IStateStorage Constructor Description PaceMakerStateStorage(PacemakerClientPool pacemakerClientPool, IStateStorage stateStorage)
StormClusterStateImpl(IStateStorage stateStorage, ILocalAssignmentsBackend assignmentsassignmentsBackend, ClusterStateContext context, boolean shouldCloseStateStorageOnDisconnect)
-
Uses of IStateStorage in org.apache.storm.daemon.worker
Methods in org.apache.storm.daemon.worker that return IStateStorage Modifier and Type Method Description IStateStorage
WorkerState. getStateStorage()
Constructors in org.apache.storm.daemon.worker with parameters of type IStateStorage Constructor 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)
-