| Modifier and Type | Method and Description |
|---|---|
static Set<NimbusInfo> |
BlobStoreUtils.getNimbodesWithLatestSequenceNumberOfBlob(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient,
String key) |
| Modifier and Type | Method and Description |
|---|---|
static void |
BlobStoreUtils.createStateInZookeeper(Map<String,Object> conf,
String key,
NimbusInfo nimbusInfo) |
void |
LocalFsBlobStore.prepare(Map<String,Object> conf,
String overrideBase,
NimbusInfo nimbusInfo,
ILeaderElector leaderElector) |
abstract void |
BlobStore.prepare(Map<String,Object> conf,
String baseDir,
NimbusInfo nimbusInfo,
ILeaderElector leaderElector)
Allows us to initialize the blob store.
|
void |
LocalFsBlobStoreSynchronizer.setNimbusInfo(NimbusInfo nimbusInfo) |
static void |
BlobStoreUtils.updateKeyForBlobStore(Map<String,Object> conf,
BlobStore blobStore,
org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient,
String key,
NimbusInfo nimbusDetails) |
| Modifier and Type | Method and Description |
|---|---|
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) |
| Constructor and Description |
|---|
KeySequenceNumber(String key,
NimbusInfo nimbusInfo) |
| Modifier and Type | Method and Description |
|---|---|
NimbusInfo |
StormClusterStateImpl.getLeader(Runnable callback) |
NimbusInfo |
IStormClusterState.getLeader(Runnable callback)
Get leader info from state store, which was written when a master gains leadership.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StormClusterStateImpl.setupBlob(String key,
NimbusInfo nimbusInfo,
Integer versionInfo) |
void |
IStormClusterState.setupBlob(String key,
NimbusInfo nimbusInfo,
Integer versionInfo) |
| Modifier and Type | Method and Description |
|---|---|
static int |
Nimbus.getVersionForKey(String key,
NimbusInfo nimbusInfo,
org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient) |
| 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) |
| Modifier and Type | Method and Description |
|---|---|
void |
HdfsBlobStore.prepare(Map<String,Object> conf,
String overrideBase,
NimbusInfo nimbusInfo,
ILeaderElector leaderElector) |
| Modifier and Type | Method and Description |
|---|---|
static NimbusInfo |
NimbusInfo.fromConf(Map<String,Object> conf) |
NimbusInfo |
ILeaderElector.getLeader()
Get the current leader’s address.
|
static NimbusInfo |
NimbusInfo.parse(String nimbusInfo) |
| Modifier and Type | Method and Description |
|---|---|
List<NimbusInfo> |
ILeaderElector.getAllNimbuses()
Get list of current nimbus addresses.
|
| Modifier and Type | Method and Description |
|---|---|
NimbusInfo |
MockLeaderElector.getLeader() |
| Modifier and Type | Method and Description |
|---|---|
List<NimbusInfo> |
MockLeaderElector.getAllNimbuses() |
| 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 |
|---|---|
NimbusInfo |
LeaderElectorImp.getLeader() |
static NimbusInfo |
Zookeeper.toNimbusInfo(org.apache.storm.shade.org.apache.curator.framework.recipes.leader.Participant participant) |
| Modifier and Type | Method and Description |
|---|---|
List<NimbusInfo> |
LeaderElectorImp.getAllNimbuses() |
Copyright © 2021 The Apache Software Foundation. All rights reserved.