Uses of Class
org.apache.storm.nimbus.NimbusInfo
-
-
Uses of NimbusInfo in org.apache.storm.blobstore
Methods in org.apache.storm.blobstore that return types with arguments of type NimbusInfo Modifier and Type Method Description static 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 NimbusInfo Modifier and Type Method Description static 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 NimbusInfo Modifier and Type Method Description static 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 Constructor Description KeySequenceNumber(String key, NimbusInfo nimbusInfo) -
Uses of NimbusInfo in org.apache.storm.cluster
Methods in org.apache.storm.cluster that return NimbusInfo Modifier and Type Method Description NimbusInfoIStormClusterState. getLeader(Runnable callback)Get leader info from state store, which was written when a master gains leadership.NimbusInfoStormClusterStateImpl. getLeader(Runnable callback)Methods in org.apache.storm.cluster with parameters of type NimbusInfo Modifier and Type Method Description voidIStormClusterState. 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 NimbusInfo Modifier and Type Method Description static 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 NimbusInfo Constructor Description Nimbus(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 NimbusInfo Modifier and Type Method Description voidHdfsBlobStore. 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 NimbusInfo Modifier and Type Method Description static NimbusInfoNimbusInfo. fromConf(Map<String,Object> conf)NimbusInfoILeaderElector. getLeader()Get the current leader's address.static NimbusInfoNimbusInfo. parse(String nimbusInfo)Methods in org.apache.storm.nimbus that return types with arguments of type NimbusInfo Modifier and Type Method Description List<NimbusInfo>ILeaderElector. getAllNimbuses()Get list of current nimbus addresses. -
Uses of NimbusInfo in org.apache.storm.testing
Methods in org.apache.storm.testing that return NimbusInfo Modifier and Type Method Description NimbusInfoMockLeaderElector. getLeader()Methods in org.apache.storm.testing that return types with arguments of type NimbusInfo Modifier and Type Method Description List<NimbusInfo>MockLeaderElector. getAllNimbuses() -
Uses of NimbusInfo in org.apache.storm.utils
Methods in org.apache.storm.utils with parameters of type NimbusInfo Modifier and Type Method Description static 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 NimbusInfo Modifier and Type Method Description NimbusInfoLeaderElectorImp. 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 Modifier and Type Method Description List<NimbusInfo>LeaderElectorImp. getAllNimbuses()
-