Package | Description |
---|---|
org.apache.storm.blobstore | |
org.apache.storm.hdfs.blobstore | |
org.apache.storm.utils | |
org.apache.storm.zookeeper |
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 |
---|---|
static boolean |
BlobStoreUtils.downloadMissingBlob(Map conf,
BlobStore blobStore,
String key,
Set<NimbusInfo> nimbusInfos) |
static boolean |
BlobStoreUtils.downloadUpdatedBlob(Map conf,
BlobStore blobStore,
String key,
Set<NimbusInfo> nimbusInfos) |
static List<String> |
BlobStoreUtils.getKeyListFromBlobStore(BlobStore blobStore) |
static void |
BlobStoreUtils.updateKeyForBlobStore(Map conf,
BlobStore blobStore,
org.apache.curator.framework.CuratorFramework zkClient,
String key,
NimbusInfo nimbusDetails) |
Constructor and Description |
---|
BlobSynchronizer(BlobStore blobStore,
Map conf) |
Modifier and Type | Class and Description |
---|---|
class |
HdfsBlobStore
Provides a HDFS file system backed blob store implementation.
|
Modifier and Type | Method and Description |
---|---|
static BlobStore |
Utils.getNimbusBlobStore(Map conf,
NimbusInfo nimbusInfo) |
static BlobStore |
Utils.getNimbusBlobStore(Map conf,
String baseDir,
NimbusInfo nimbusInfo) |
Modifier and Type | Method and Description |
---|---|
static org.apache.curator.framework.recipes.leader.LeaderLatchListener |
Zookeeper.leaderLatchListenerImpl(Map conf,
org.apache.curator.framework.CuratorFramework zk,
BlobStore blobStore,
org.apache.curator.framework.recipes.leader.LeaderLatch leaderLatch) |
static ILeaderElector |
Zookeeper.zkLeaderElector(Map conf,
org.apache.curator.framework.CuratorFramework zkClient,
BlobStore blobStore)
Get master leader elector.
|
protected ILeaderElector |
Zookeeper.zkLeaderElectorImpl(Map conf,
org.apache.curator.framework.CuratorFramework zk,
BlobStore blobStore) |
Constructor and Description |
---|
LeaderElectorImp(Map conf,
List<String> servers,
org.apache.curator.framework.CuratorFramework zk,
String leaderlockPath,
String id,
AtomicReference<org.apache.curator.framework.recipes.leader.LeaderLatch> leaderLatch,
AtomicReference<org.apache.curator.framework.recipes.leader.LeaderLatchListener> leaderLatchListener,
BlobStore blobStore) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.