Uses of Interface
org.apache.storm.nimbus.ILeaderElector
Packages that use ILeaderElector
Package
Description
- 
Uses of ILeaderElector in org.apache.stormMethods in org.apache.storm with parameters of type ILeaderElectorModifier and TypeMethodDescriptionLocalCluster.Builder.withLeaderElector(ILeaderElector leaderElector) Use the following leaderElector instead of the one in the config.
- 
Uses of ILeaderElector in org.apache.storm.blobstoreMethods in org.apache.storm.blobstore with parameters of type ILeaderElectorModifier and TypeMethodDescriptionabstract voidBlobStore.prepare(Map<String, Object> conf, String baseDir, NimbusInfo nimbusInfo, ILeaderElector leaderElector) Allows us to initialize the blob store.voidLocalFsBlobStore.prepare(Map<String, Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector) abstract voidBlobStore.setLeaderElector(ILeaderElector leaderElector) Sets leader elector (only used by LocalFsBlobStore to help sync blobs between Nimbi.voidLocalFsBlobStore.setLeaderElector(ILeaderElector leaderElector) Sets leader elector (only used by LocalFsBlobStore to help sync blobs between Nimbi.
- 
Uses of ILeaderElector in org.apache.storm.daemon.nimbusConstructors in org.apache.storm.daemon.nimbus with parameters of type ILeaderElectorModifierConstructorDescriptionNimbus(Map<String, Object> conf, INimbus inimbus, IStormClusterState stormClusterState, NimbusInfo hostPortInfo, BlobStore blobStore, TopoCache topoCache, ILeaderElector leaderElector, IGroupMappingServiceProvider groupMapper, StormMetricsRegistry metricsRegistry) Nimbus(Map<String, Object> conf, INimbus inimbus, IStormClusterState stormClusterState, NimbusInfo hostPortInfo, BlobStore blobStore, ILeaderElector leaderElector, IGroupMappingServiceProvider groupMapper, StormMetricsRegistry metricsRegistry) 
- 
Uses of ILeaderElector in org.apache.storm.hdfs.blobstoreMethods in org.apache.storm.hdfs.blobstore with parameters of type ILeaderElectorModifier and TypeMethodDescriptionvoidHdfsBlobStore.prepare(Map<String, Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector) voidHdfsBlobStore.setLeaderElector(ILeaderElector leaderElector) Sets leader elector (only used by LocalFsBlobStore to help sync blobs between Nimbi.
- 
Uses of ILeaderElector in org.apache.storm.nimbusConstructors in org.apache.storm.nimbus with parameters of type ILeaderElectorModifierConstructorDescriptionLeaderListenerCallback(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 ILeaderElector in org.apache.storm.testingClasses in org.apache.storm.testing that implement ILeaderElector
- 
Uses of ILeaderElector in org.apache.storm.utilsMethods in org.apache.storm.utils with parameters of type ILeaderElectorModifier and TypeMethodDescriptionstatic BlobStoreServerUtils.getNimbusBlobStore(Map<String, Object> conf, String baseDir, NimbusInfo nimbusInfo, ILeaderElector leaderElector) static BlobStoreServerUtils.getNimbusBlobStore(Map<String, Object> conf, NimbusInfo nimbusInfo, ILeaderElector leaderElector) 
- 
Uses of ILeaderElector in org.apache.storm.zookeeperClasses in org.apache.storm.zookeeper that implement ILeaderElectorMethods in org.apache.storm.zookeeper that return ILeaderElectorModifier and TypeMethodDescriptionstatic ILeaderElectorZookeeper.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 ILeaderElectorZookeeper.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) Methods in org.apache.storm.zookeeper with parameters of type ILeaderElectorModifier and TypeMethodDescriptionorg.apache.storm.shade.org.apache.curator.framework.recipes.leader.LeaderLatchListenerLeaderListenerCallbackFactory.create(ILeaderElector elector)