| Package | Description |
|---|---|
| org.apache.storm | |
| org.apache.storm.daemon.nimbus | |
| org.apache.storm.nimbus | |
| org.apache.storm.zookeeper |
| Modifier and Type | Method and Description |
|---|---|
LocalCluster.Builder |
LocalCluster.Builder.withTopoCache(TopoCache topoCache)
Use the following topo cache instead of creating out own.
|
| Constructor and Description |
|---|
Nimbus(Map<String,Object> conf,
INimbus inimbus,
IStormClusterState stormClusterState,
NimbusInfo hostPortInfo,
BlobStore blobStore,
TopoCache topoCache,
ILeaderElector leaderElector,
IGroupMappingServiceProvider groupMapper,
StormMetricsRegistry metricsRegistry) |
| 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 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 © 2022 The Apache Software Foundation. All rights reserved.