Uses of Class
org.apache.storm.daemon.nimbus.TopoCache
-
Packages that use TopoCache Package Description org.apache.storm org.apache.storm.daemon.nimbus org.apache.storm.nimbus org.apache.storm.zookeeper -
-
Uses of TopoCache in org.apache.storm
Methods in org.apache.storm with parameters of type TopoCache Modifier and Type Method Description LocalCluster.Builder
LocalCluster.Builder. withTopoCache(TopoCache topoCache)
Use the following topo cache instead of creating out own. -
Uses of TopoCache in org.apache.storm.daemon.nimbus
Constructors in org.apache.storm.daemon.nimbus with parameters of type TopoCache Constructor Description Nimbus(Map<String,Object> conf, INimbus inimbus, IStormClusterState stormClusterState, NimbusInfo hostPortInfo, BlobStore blobStore, TopoCache topoCache, ILeaderElector leaderElector, IGroupMappingServiceProvider groupMapper, StormMetricsRegistry metricsRegistry)
-
Uses of TopoCache in org.apache.storm.nimbus
Constructors in org.apache.storm.nimbus with parameters of type TopoCache Constructor 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)
Creates aLeaderListenerCallback
. -
Uses of TopoCache in org.apache.storm.zookeeper
Methods in org.apache.storm.zookeeper with parameters of type TopoCache Modifier and Type Method 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, Object submitLock)
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, Object submitLock)
Constructors in org.apache.storm.zookeeper with parameters of type TopoCache Constructor 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, Object submitLock)
-