Uses of Class
org.apache.storm.blobstore.BlobStore
Package
Description
-
Uses of BlobStore in org.apache.storm
Modifier and TypeMethodDescriptionLocalCluster.Builder.withBlobStore
(BlobStore store) Use the following blobstore instead of the one in the config. -
Uses of BlobStore in org.apache.storm.blobstore
Modifier and TypeClassDescriptionclass
Provides a local file system backed blob store implementation for Nimbus.Modifier and TypeMethodDescriptionprotected 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) 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) ModifierConstructorDescriptionLocalFsBlobStoreSynchronizer
(BlobStore blobStore, Map<String, Object> conf) LocalModeClientBlobStore
(BlobStore wrapped) -
Uses of BlobStore in org.apache.storm.daemon.nimbus
Modifier and TypeMethodDescriptionNimbus.topoIdsToClean
(IStormClusterState state, BlobStore store, Map<String, Object> conf) ModifierConstructorDescriptionNimbus
(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 BlobStore in org.apache.storm.hdfs.blobstore
Modifier and TypeClassDescriptionclass
Provides a HDFS file system backed blob store implementation. -
Uses of BlobStore in org.apache.storm.nimbus
ModifierConstructorDescriptionLeaderListenerCallback
(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
Modifier and TypeMethodDescriptionstatic 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) Modifier and TypeMethodDescriptionstatic void
Utils.validateTopologyBlobStoreMap
(Map<String, Object> topoConf, BlobStore blobStore) Validate topology blobstore map. -
Uses of BlobStore in org.apache.storm.zookeeper
Modifier and TypeMethodDescriptionstatic 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) ModifierConstructorDescriptionLeaderListenerCallbackFactory
(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)