Modifier and Type | Method and Description |
---|---|
LocalCluster.Builder |
LocalCluster.Builder.withBlobStore(BlobStore store)
Use the following blobstore instead of the one in the config.
|
Modifier and Type | Class and Description |
---|---|
class |
LocalFsBlobStore
Provides a local file system backed blob store implementation for Nimbus.
|
Modifier and Type | Method and 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) |
Constructor and Description |
---|
LocalFsBlobStoreSynchronizer(BlobStore blobStore,
Map<String,Object> conf) |
LocalModeClientBlobStore(BlobStore wrapped) |
Modifier and Type | Method and Description |
---|---|
static Set<String> |
Nimbus.topoIdsToClean(IStormClusterState state,
BlobStore store,
Map<String,Object> conf) |
Constructor and Description |
---|
Nimbus(Map<String,Object> conf,
INimbus inimbus,
IStormClusterState stormClusterState,
NimbusInfo hostPortInfo,
BlobStore blobStore,
ILeaderElector leaderElector,
IGroupMappingServiceProvider groupMapper,
StormMetricsRegistry metricsRegistry) |
Nimbus(Map<String,Object> conf,
INimbus inimbus,
IStormClusterState stormClusterState,
NimbusInfo hostPortInfo,
BlobStore blobStore,
TopoCache topoCache,
ILeaderElector leaderElector,
IGroupMappingServiceProvider groupMapper,
StormMetricsRegistry metricsRegistry) |
TopoCache(BlobStore store,
Map<String,Object> conf) |
Modifier and Type | Class and Description |
---|---|
class |
HdfsBlobStore
Provides a HDFS file system backed blob store implementation.
|
Constructor and 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)
Constructor for .
|
Modifier and Type | Method and Description |
---|---|
static BlobStore |
ServerUtils.getNimbusBlobStore(Map<String,Object> conf,
NimbusInfo nimbusInfo,
ILeaderElector leaderElector) |
static BlobStore |
ServerUtils.getNimbusBlobStore(Map<String,Object> conf,
String baseDir,
NimbusInfo nimbusInfo,
ILeaderElector leaderElector) |
Modifier and Type | Method and Description |
---|---|
static void |
Utils.validateTopologyBlobStoreMap(Map<String,Object> topoConf,
BlobStore blobStore)
Validate topology blobstore map.
|
Modifier and Type | Method and 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)
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) |
Constructor and 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) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.