Uses of Class
org.apache.storm.blobstore.BlobStore
Packages that use BlobStore
Package
Description
-
Uses of BlobStore in org.apache.storm
Methods in org.apache.storm with parameters of type BlobStoreModifier 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
Subclasses of BlobStore in org.apache.storm.blobstoreModifier and TypeClassDescriptionclassProvides a local file system backed blob store implementation for Nimbus.Methods in org.apache.storm.blobstore with parameters of type BlobStoreModifier and TypeMethodDescriptionprotected 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) 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 BlobStoreModifierConstructorDescriptionLocalFsBlobStoreSynchronizer(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 BlobStoreModifier and TypeMethodDescriptionNimbus.topoIdsToClean(IStormClusterState state, BlobStore store, Map<String, Object> conf) Constructors in org.apache.storm.daemon.nimbus with parameters of type BlobStoreModifierConstructorDescriptionNimbus(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
Subclasses of BlobStore in org.apache.storm.hdfs.blobstoreModifier and TypeClassDescriptionclassProvides 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 BlobStoreModifierConstructorDescriptionLeaderListenerCallback(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 BlobStoreModifier 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) Methods in org.apache.storm.utils with parameters of type BlobStoreModifier and TypeMethodDescriptionstatic 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 BlobStoreModifier and TypeMethodDescriptionstatic 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 BlobStoreModifierConstructorDescriptionLeaderListenerCallbackFactory(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)