Package | Description |
---|---|
org.apache.storm.blobstore | |
org.apache.storm.cluster | |
org.apache.storm.hdfs.blobstore | |
org.apache.storm.nimbus | |
org.apache.storm.utils | |
org.apache.storm.zookeeper |
Modifier and Type | Method and Description |
---|---|
static Set<NimbusInfo> |
BlobStoreUtils.getNimbodesWithLatestSequenceNumberOfBlob(org.apache.curator.framework.CuratorFramework zkClient,
String key) |
Modifier and Type | Method and Description |
---|---|
static void |
BlobStoreUtils.createStateInZookeeper(Map conf,
String key,
NimbusInfo nimbusInfo) |
void |
LocalFsBlobStore.prepare(Map conf,
String overrideBase,
NimbusInfo nimbusInfo) |
abstract void |
BlobStore.prepare(Map conf,
String baseDir,
NimbusInfo nimbusInfo)
Allows us to initialize the blob store
|
void |
BlobSynchronizer.setNimbusInfo(NimbusInfo nimbusInfo) |
static void |
BlobStoreUtils.updateKeyForBlobStore(Map conf,
BlobStore blobStore,
org.apache.curator.framework.CuratorFramework zkClient,
String key,
NimbusInfo nimbusDetails) |
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) |
Constructor and Description |
---|
KeySequenceNumber(String key,
NimbusInfo nimbusInfo) |
Modifier and Type | Method and Description |
---|---|
void |
StormClusterStateImpl.setupBlobstore(String key,
NimbusInfo nimbusInfo,
Integer versionInfo) |
void |
IStormClusterState.setupBlobstore(String key,
NimbusInfo nimbusInfo,
Integer versionInfo) |
Modifier and Type | Method and Description |
---|---|
void |
HdfsBlobStore.prepare(Map conf,
String overrideBase,
NimbusInfo nimbusInfo) |
Modifier and Type | Method and Description |
---|---|
static NimbusInfo |
NimbusInfo.fromConf(Map conf) |
NimbusInfo |
ILeaderElector.getLeader() |
static NimbusInfo |
NimbusInfo.parse(String nimbusInfo) |
Modifier and Type | Method and Description |
---|---|
List<NimbusInfo> |
ILeaderElector.getAllNimbuses() |
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 |
---|---|
NimbusInfo |
LeaderElectorImp.getLeader() |
static NimbusInfo |
Zookeeper.toNimbusInfo(org.apache.curator.framework.recipes.leader.Participant participant) |
Modifier and Type | Method and Description |
---|---|
List<NimbusInfo> |
LeaderElectorImp.getAllNimbuses() |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.