Uses of Interface
org.apache.storm.nimbus.ILeaderElector
Packages that use ILeaderElector
Package
Description
-
Uses of ILeaderElector in org.apache.storm
Methods 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.blobstore
Methods 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.nimbus
Constructors 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.blobstore
Methods 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.nimbus
Constructors 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.testing
Classes in org.apache.storm.testing that implement ILeaderElector -
Uses of ILeaderElector in org.apache.storm.utils
Methods 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.zookeeper
Classes 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)