## Uses of Interface
org.apache.storm.cluster.IStormClusterState

- Packages that use IStormClusterState
  Package | Description
  --- | ---
  org.apache.storm |
  org.apache.storm.cluster |
  org.apache.storm.daemon.nimbus |
  org.apache.storm.daemon.supervisor |
  org.apache.storm.daemon.supervisor.timer |
  org.apache.storm.daemon.worker |
  org.apache.storm.executor |
  org.apache.storm.executor.error |
  org.apache.storm.nimbus |
  org.apache.storm.security.auth.workertoken |
  org.apache.storm.stats |
  org.apache.storm.zookeeper |

- - ### Uses of IStormClusterState in org.apache.storm

    Methods in org.apache.storm that return IStormClusterState
    Modifier and Type | Method and Description
    --- | ---
    `IStormClusterState` | LocalCluster.`getClusterState()`
    `IStormClusterState` | ILocalCluster.`getClusterState()` This is intended for internal testing only.

    Methods in org.apache.storm with parameters of type IStormClusterState
    Modifier and Type | Method and Description
    --- | ---
    `LocalCluster.Builder` | LocalCluster.Builder.`withClusterState(IStormClusterState clusterState)` Use the following clusterState instead of the one in the config.

  - ### Uses of IStormClusterState in org.apache.storm.cluster

    Classes in org.apache.storm.cluster that implement IStormClusterState
    Modifier and Type | Class and Description
    --- | ---
    `class` | `StormClusterStateImpl`

    Methods in org.apache.storm.cluster that return IStormClusterState
    Modifier and Type | Method and Description
    --- | ---
    `static IStormClusterState` | ClusterUtils.`mkStormClusterState(Object stateStorage, ClusterStateContext context)`
    `static IStormClusterState` | ClusterUtils.`mkStormClusterState(Object stateStorage, ILocalAssignmentsBackend backend, ClusterStateContext context)`
    `IStormClusterState` | ClusterUtils.`mkStormClusterStateImpl(Object stateStorage, ILocalAssignmentsBackend backend, ClusterStateContext context)`

  - ### Uses of IStormClusterState in org.apache.storm.daemon.nimbus

    Methods in org.apache.storm.daemon.nimbus with parameters of type IStormClusterState
    Modifier and Type | Method and Description
    --- | ---
    `static Set<String>` | Nimbus.`topoIdsToClean(IStormClusterState state, BlobStore store, Map<String,Object> conf)`

    Constructors in org.apache.storm.daemon.nimbus with parameters of type IStormClusterState
    Constructor and Description
    `Nimbus(Map<String,Object> conf, INimbus inimbus, IStormClusterState stormClusterState, NimbusInfo hostPortInfo, BlobStore blobStore, ILeaderElector leaderElector, IGroupMappingServiceProvider groupMapper, StormMetricsRegistry metricsRegistry)`
    `Nimbus(Map<String,Object> conf, INimbus inimbus, IStormClusterState stormClusterState, NimbusInfo hostPortInfo, BlobStore blobStore, TopoCache topoCache, ILeaderElector leaderElector, IGroupMappingServiceProvider groupMapper, StormMetricsRegistry metricsRegistry)`

  - ### Uses of IStormClusterState in org.apache.storm.daemon.supervisor

    Methods in org.apache.storm.daemon.supervisor that return IStormClusterState
    Modifier and Type | Method and Description
    --- | ---
    `IStormClusterState` | Supervisor.`getStormClusterState()`

    Methods in org.apache.storm.daemon.supervisor with parameters of type IStormClusterState
    Modifier and Type | Method and Description
    --- | ---
    `protected Map<String,Assignment>` | ReadClusterState.`getAssignmentsSnapshot(IStormClusterState stormClusterState)`
    `protected Map<String,List<ProfileRequest>>` | ReadClusterState.`getProfileActions(IStormClusterState stormClusterState, List<String> stormIds)`

    Constructors in org.apache.storm.daemon.supervisor with parameters of type IStormClusterState
    Constructor and Description
    `Slot(AsyncLocalizer localizer, Map<String,Object> conf, ContainerLauncher containerLauncher, String host, int port, LocalState localState, IStormClusterState clusterState, ISupervisor supervisor, AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments, OnlyLatestExecutor<Integer> metricsExec, WorkerMetricsProcessor metricsProcessor, org.apache.storm.daemon.supervisor.SlotMetrics slotMetrics)`

  - ### Uses of IStormClusterState in org.apache.storm.daemon.supervisor.timer

    Methods in org.apache.storm.daemon.supervisor.timer with parameters of type IStormClusterState
    Modifier and Type | Method and Description
    --- | ---
    `void` | SynchronizeAssignments.`getAssignmentsFromMaster(Map conf, IStormClusterState clusterState, String node)` Used by `Supervisor` to fetch assignments when start up.

  - ### Uses of IStormClusterState in org.apache.storm.daemon.worker

    Constructors in org.apache.storm.daemon.worker with parameters of type IStormClusterState
    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)`

  - ### Uses of IStormClusterState in org.apache.storm.executor

    Fields in org.apache.storm.executor declared as IStormClusterState
    Modifier and Type | Field and Description
    --- | ---
    `protected IStormClusterState` | Executor.`stormClusterState`

    Methods in org.apache.storm.executor that return IStormClusterState
    Modifier and Type | Method and Description
    --- | ---
    `IStormClusterState` | Executor.`getStormClusterState()`

  - ### Uses of IStormClusterState in org.apache.storm.executor.error

    Constructors in org.apache.storm.executor.error with parameters of type IStormClusterState
    Constructor and Description
    `ReportError(Map<String,Object> topoConf, IStormClusterState stormClusterState, String stormId, String componentId, WorkerTopologyContext workerTopologyContext)`

  - ### Uses of IStormClusterState in org.apache.storm.nimbus

    Constructors in org.apache.storm.nimbus with parameters of type IStormClusterState
    Constructor and Description
    `LeaderListenerCallback(Map conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore, ILeaderElector leaderElector, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry)` Constructor for .

  - ### Uses of IStormClusterState in org.apache.storm.security.auth.workertoken

    Constructors in org.apache.storm.security.auth.workertoken with parameters of type IStormClusterState
    Constructor and Description
    `WorkerTokenManager(Map<String,Object> daemonConf, IStormClusterState state)` Constructor.

  - ### Uses of IStormClusterState in org.apache.storm.stats

    Methods in org.apache.storm.stats with parameters of type IStormClusterState
    Modifier and Type | Method and Description
    --- | ---
    `static TopologyPageInfo` | StatsUtil.`aggTopoExecsStats(String topologyId, Map exec2nodePort, Map task2component, Map<List<Integer>,Map<String,Object>> beats, StormTopology topology, String window, boolean includeSys, IStormClusterState clusterState)` aggregate topo executors stats.

  - ### Uses of IStormClusterState in org.apache.storm.zookeeper

    Methods in org.apache.storm.zookeeper with parameters of type IStormClusterState
    Modifier and Type | Method and Description
    --- | ---
    `static ILeaderElector` | Zookeeper.`zkLeaderElector(Map<String,Object> conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, BlobStore blobStore, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry)` Get master leader elector.
    `protected ILeaderElector` | Zookeeper.`zkLeaderElectorImpl(Map<String,Object> conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry)`

    Constructors in org.apache.storm.zookeeper with parameters of type IStormClusterState
    Constructor and Description
    `LeaderListenerCallbackFactory(Map<String,Object> conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry)`

Copyright © 2021 The Apache Software Foundation. All rights reserved.