Uses of Class
org.apache.storm.blobstore.BlobStore

Packages that use BlobStore

Package	Description
org.apache.storm
org.apache.storm.blobstore
org.apache.storm.daemon.nimbus
org.apache.storm.hdfs.blobstore
org.apache.storm.nimbus
org.apache.storm.utils
org.apache.storm.zookeeper

Uses of BlobStore in org.apache.storm

Methods in org.apache.storm with parameters of type BlobStore

Modifier and Type	Method	Description
LocalCluster.Builder	LocalCluster.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
class	LocalFsBlobStore	Provides 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 void	MigrateBlobs.copyBlobStoreKeys(BlobStore bsFrom, Subject whoFrom, BlobStore bsTo, Subject whoTo)
protected static void	MigrateBlobs.deleteAllBlobStoreKeys(BlobStore bs, Subject who)
static 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)
static List<String>	BlobStoreUtils.getKeyListFromBlobStore(BlobStore blobStore)
static void	MigratorMain.listBlobStoreKeys(BlobStore bs, Subject who)
static void	BlobStoreUtils.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
class	HdfsBlobStore	Provides 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 a LeaderListenerCallback.

Uses of BlobStore in org.apache.storm.utils

Methods in org.apache.storm.utils that return BlobStore

Modifier and Type	Method	Description
static 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)

Methods in org.apache.storm.utils with parameters of type BlobStore

Modifier and Type	Method	Description
static void	Utils.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 ILeaderElector	Zookeeper.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 ILeaderElector	Zookeeper.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)