Uses of Class
org.apache.storm.blobstore.BlobStore
-
-
Uses of BlobStore in org.apache.storm
Methods in org.apache.storm with parameters of type BlobStore Modifier and Type Method Description LocalCluster.BuilderLocalCluster.Builder. withBlobStore(BlobStore store)Use the following blobstore instead of the one in the config. -
Uses of BlobStore in org.apache.storm.blobstore
Subclasses of BlobStore in org.apache.storm.blobstore Modifier and Type Class Description classLocalFsBlobStoreProvides a local file system backed blob store implementation for Nimbus.Methods in org.apache.storm.blobstore with parameters of type BlobStore Modifier and Type Method Description protected static voidMigrateBlobs. copyBlobStoreKeys(BlobStore bsFrom, Subject whoFrom, BlobStore bsTo, Subject whoTo)protected static voidMigrateBlobs. deleteAllBlobStoreKeys(BlobStore bs, Subject who)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)static List<String>BlobStoreUtils. getKeyListFromBlobStore(BlobStore blobStore)static voidMigratorMain. listBlobStoreKeys(BlobStore bs, Subject who)static voidBlobStoreUtils. updateKeyForBlobStore(Map<String,Object> conf, BlobStore blobStore, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key, NimbusInfo nimbusDetails)Constructors in org.apache.storm.blobstore with parameters of type BlobStore Constructor Description LocalFsBlobStoreSynchronizer(BlobStore blobStore, Map<String,Object> conf)LocalModeClientBlobStore(BlobStore wrapped) -
Uses of BlobStore in org.apache.storm.daemon.nimbus
Methods in org.apache.storm.daemon.nimbus with parameters of type BlobStore Modifier and Type Method Description static Set<String>Nimbus. topoIdsToClean(IStormClusterState state, BlobStore store, Map<String,Object> conf)Constructors in org.apache.storm.daemon.nimbus with parameters of type BlobStore 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)TopoCache(BlobStore store, Map<String,Object> conf) -
Uses of BlobStore in org.apache.storm.hdfs.blobstore
Subclasses of BlobStore in org.apache.storm.hdfs.blobstore Modifier and Type Class Description classHdfsBlobStoreProvides a HDFS file system backed blob store implementation. -
Uses of BlobStore in org.apache.storm.nimbus
Constructors in org.apache.storm.nimbus with parameters of type BlobStore Constructor Description LeaderListenerCallback(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 BlobStore in org.apache.storm.utils
Methods in org.apache.storm.utils that return BlobStore 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)Methods in org.apache.storm.utils with parameters of type BlobStore Modifier and Type Method Description static voidUtils. validateTopologyBlobStoreMap(Map<String,Object> topoConf, BlobStore blobStore)Validate topology blobstore map. -
Uses of BlobStore in org.apache.storm.zookeeper
Methods in org.apache.storm.zookeeper with parameters of type BlobStore Modifier and Type Method Description static ILeaderElectorZookeeper. 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 ILeaderElectorZookeeper. 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)Constructors in org.apache.storm.zookeeper with parameters of type BlobStore Constructor Description LeaderListenerCallbackFactory(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)
-