Uses of Class
org.apache.storm.nimbus.NimbusInfo
Packages that use NimbusInfo
Package
Description
- 
Uses of NimbusInfo in org.apache.storm.blobstoreMethods in org.apache.storm.blobstore that return types with arguments of type NimbusInfoModifier and TypeMethodDescriptionstatic Set<NimbusInfo>BlobStoreUtils.getNimbodesWithLatestSequenceNumberOfBlob(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key) Methods in org.apache.storm.blobstore with parameters of type NimbusInfoModifier and TypeMethodDescriptionstatic voidBlobStoreUtils.createStateInZookeeper(Map<String, Object> conf, String key, NimbusInfo nimbusInfo) abstract 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) voidLocalFsBlobStoreSynchronizer.setNimbusInfo(NimbusInfo nimbusInfo) static voidBlobStoreUtils.updateKeyForBlobStore(Map<String, Object> conf, BlobStore blobStore, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key, NimbusInfo nimbusDetails) Method parameters in org.apache.storm.blobstore with type arguments of type NimbusInfoModifier and TypeMethodDescriptionstatic booleanBlobStoreUtils.downloadMissingBlob(Map<String, Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos) static booleanBlobStoreUtils.downloadUpdatedBlob(Map<String, Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos) Constructors in org.apache.storm.blobstore with parameters of type NimbusInfo
- 
Uses of NimbusInfo in org.apache.storm.clusterMethods in org.apache.storm.cluster that return NimbusInfoModifier and TypeMethodDescriptionGet leader info from state store, which was written when a master gains leadership.Methods in org.apache.storm.cluster with parameters of type NimbusInfoModifier and TypeMethodDescriptionvoidIStormClusterState.setupBlob(String key, NimbusInfo nimbusInfo, Integer versionInfo) voidStormClusterStateImpl.setupBlob(String key, NimbusInfo nimbusInfo, Integer versionInfo) 
- 
Uses of NimbusInfo in org.apache.storm.daemon.nimbusMethods in org.apache.storm.daemon.nimbus with parameters of type NimbusInfoModifier and TypeMethodDescriptionstatic intNimbus.getVersionForKey(String key, NimbusInfo nimbusInfo, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient) Constructors in org.apache.storm.daemon.nimbus with parameters of type NimbusInfoModifierConstructorDescriptionNimbus(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.blobstoreMethods in org.apache.storm.hdfs.blobstore with parameters of type NimbusInfoModifier and TypeMethodDescriptionvoidHdfsBlobStore.prepare(Map<String, Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector) 
- 
Uses of NimbusInfo in org.apache.storm.nimbusMethods in org.apache.storm.nimbus that return NimbusInfoModifier and TypeMethodDescriptionstatic NimbusInfoILeaderElector.getLeader()Get the current leader's address.static NimbusInfoMethods in org.apache.storm.nimbus that return types with arguments of type NimbusInfoModifier and TypeMethodDescriptionILeaderElector.getAllNimbuses()Get list of current nimbus addresses.
- 
Uses of NimbusInfo in org.apache.storm.testingMethods in org.apache.storm.testing that return NimbusInfoMethods in org.apache.storm.testing that return types with arguments of type NimbusInfo
- 
Uses of NimbusInfo in org.apache.storm.utilsMethods in org.apache.storm.utils with parameters of type NimbusInfoModifier 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 NimbusInfo in org.apache.storm.zookeeperMethods in org.apache.storm.zookeeper that return NimbusInfoModifier and TypeMethodDescriptionLeaderElectorImp.getLeader()static NimbusInfoZookeeper.toNimbusInfo(org.apache.storm.shade.org.apache.curator.framework.recipes.leader.Participant participant) Methods in org.apache.storm.zookeeper that return types with arguments of type NimbusInfo