Uses of Interface
org.apache.storm.nimbus.ILeaderElector
Package
Description
-
Uses of ILeaderElector in org.apache.storm
Modifier 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
Modifier 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
ModifierConstructorDescriptionNimbus
(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
Modifier 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
ModifierConstructorDescriptionLeaderListenerCallback
(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
-
Uses of ILeaderElector in org.apache.storm.utils
Modifier 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
Modifier 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, 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) Modifier and TypeMethodDescriptionorg.apache.storm.shade.org.apache.curator.framework.recipes.leader.LeaderLatchListener
LeaderListenerCallbackFactory.create
(ILeaderElector elector)