| Package | Description | 
|---|---|
| org.apache.storm | |
| org.apache.storm.daemon.nimbus | |
| org.apache.storm.nimbus | |
| org.apache.storm.zookeeper | 
| Modifier and Type | Method and Description | 
|---|---|
LocalCluster.Builder | 
LocalCluster.Builder.withTopoCache(TopoCache topoCache)
Use the following topo cache instead of creating out own. 
 | 
| Constructor and Description | 
|---|
Nimbus(Map<String,Object> conf,
      INimbus inimbus,
      IStormClusterState stormClusterState,
      NimbusInfo hostPortInfo,
      BlobStore blobStore,
      TopoCache topoCache,
      ILeaderElector leaderElector,
      IGroupMappingServiceProvider groupMapper,
      StormMetricsRegistry metricsRegistry)  | 
| 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 . 
 | 
| 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)  | 
| 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 © 2019 The Apache Software Foundation. All rights reserved.