Uses of Class
org.apache.storm.nimbus.NimbusInfo
Package
Description
-
Uses of NimbusInfo in org.apache.storm.blobstore
Modifier and TypeMethodDescriptionstatic Set<NimbusInfo>
BlobStoreUtils.getNimbodesWithLatestSequenceNumberOfBlob
(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key) Modifier and TypeMethodDescriptionstatic void
BlobStoreUtils.createStateInZookeeper
(Map<String, Object> conf, String key, NimbusInfo nimbusInfo) abstract 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) void
LocalFsBlobStoreSynchronizer.setNimbusInfo
(NimbusInfo nimbusInfo) static void
BlobStoreUtils.updateKeyForBlobStore
(Map<String, Object> conf, BlobStore blobStore, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key, NimbusInfo nimbusDetails) Modifier and TypeMethodDescriptionstatic boolean
BlobStoreUtils.downloadMissingBlob
(Map<String, Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos) static boolean
BlobStoreUtils.downloadUpdatedBlob
(Map<String, Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos) -
Uses of NimbusInfo in org.apache.storm.cluster
Modifier and TypeMethodDescriptionGet leader info from state store, which was written when a master gains leadership.Modifier and TypeMethodDescriptionvoid
IStormClusterState.setupBlob
(String key, NimbusInfo nimbusInfo, Integer versionInfo) void
StormClusterStateImpl.setupBlob
(String key, NimbusInfo nimbusInfo, Integer versionInfo) -
Uses of NimbusInfo in org.apache.storm.daemon.nimbus
Modifier and TypeMethodDescriptionstatic int
Nimbus.getVersionForKey
(String key, NimbusInfo nimbusInfo, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient) 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 NimbusInfo in org.apache.storm.hdfs.blobstore
Modifier and TypeMethodDescriptionvoid
HdfsBlobStore.prepare
(Map<String, Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector) -
Uses of NimbusInfo in org.apache.storm.nimbus
Modifier and TypeMethodDescriptionstatic NimbusInfo
ILeaderElector.getLeader()
Get the current leader's address.static NimbusInfo
Modifier and TypeMethodDescriptionILeaderElector.getAllNimbuses()
Get list of current nimbus addresses. -
Uses of NimbusInfo in org.apache.storm.testing
-
Uses of NimbusInfo 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 NimbusInfo in org.apache.storm.zookeeper
Modifier and TypeMethodDescriptionLeaderElectorImp.getLeader()
static NimbusInfo
Zookeeper.toNimbusInfo
(org.apache.storm.shade.org.apache.curator.framework.recipes.leader.Participant participant)