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 void
BlobStore.prepare
(Map<String, Object> conf, String baseDir, NimbusInfo nimbusInfo, ILeaderElector leaderElector) Allows us to initialize the blob store.void
LocalFsBlobStore.prepare
(Map<String, Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector) abstract void
BlobStore.setLeaderElector
(ILeaderElector leaderElector) Sets leader elector (only used by LocalFsBlobStore to help sync blobs between Nimbi.void
LocalFsBlobStore.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 TypeMethodDescriptionvoid
HdfsBlobStore.prepare
(Map<String, Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector) void
HdfsBlobStore.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 BlobStore
ServerUtils.getNimbusBlobStore
(Map<String, Object> conf, String baseDir, NimbusInfo nimbusInfo, ILeaderElector leaderElector) static BlobStore
ServerUtils.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 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) Methods in org.apache.storm.zookeeper with parameters of type ILeaderElectorModifier and TypeMethodDescriptionorg.apache.storm.shade.org.apache.curator.framework.recipes.leader.LeaderLatchListener
LeaderListenerCallbackFactory.create
(ILeaderElector elector)