Uses of Class
org.apache.storm.nimbus.NimbusInfo
Packages that use NimbusInfo
Package
Description
-
Uses of NimbusInfo in org.apache.storm.blobstore
Methods 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.cluster
Methods 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.nimbus
Methods 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.blobstore
Methods 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.nimbus
Methods 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.testing
Methods 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.utils
Methods 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.zookeeper
Methods 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