Uses of Interface
org.apache.storm.cluster.IStateStorage
Packages that use IStateStorage
-
Uses of IStateStorage in org.apache.storm.cluster
Classes in org.apache.storm.cluster that implement IStateStorageMethods in org.apache.storm.cluster that return IStateStorageModifier and TypeMethodDescriptionstatic IStateStorage
ClusterUtils.mkStateStorage
(Map<String, Object> config, Map<String, Object> authConf, ClusterStateContext context) ClusterUtils.mkStateStorageImpl
(Map<String, Object> config, Map<String, Object> authConf, ClusterStateContext context) PaceMakerStateStorageFactory.mkStore
(Map<String, Object> config, Map<String, Object> authConf, ClusterStateContext context) StateStorageFactory.mkStore
(Map<String, Object> config, Map<String, Object> authConf, ClusterStateContext context) ZKStateStorageFactory.mkStore
(Map<String, Object> config, Map<String, Object> authConf, ClusterStateContext context) Constructors in org.apache.storm.cluster with parameters of type IStateStorageModifierConstructorDescriptionPaceMakerStateStorage
(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 IStateStorageConstructors in org.apache.storm.daemon.worker with parameters of type IStateStorageModifierConstructorDescriptionWorkerState
(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)