Package | Description |
---|---|
org.apache.storm.cluster | |
org.apache.storm.daemon.worker |
Modifier and Type | Class and Description |
---|---|
class |
PaceMakerStateStorage |
class |
ZKStateStorage |
Modifier and Type | Method and Description |
---|---|
static IStateStorage |
ClusterUtils.mkStateStorage(Map<String,Object> config,
Map<String,Object> authConf,
ClusterStateContext context) |
IStateStorage |
ClusterUtils.mkStateStorageImpl(Map<String,Object> config,
Map<String,Object> authConf,
ClusterStateContext context) |
IStateStorage |
ZKStateStorageFactory.mkStore(Map<String,Object> config,
Map<String,Object> authConf,
ClusterStateContext context) |
IStateStorage |
PaceMakerStateStorageFactory.mkStore(Map<String,Object> config,
Map<String,Object> authConf,
ClusterStateContext context) |
IStateStorage |
StateStorageFactory.mkStore(Map<String,Object> config,
Map<String,Object> authConf,
ClusterStateContext context) |
Constructor and Description |
---|
PaceMakerStateStorage(PacemakerClientPool pacemakerClientPool,
IStateStorage stateStorage) |
StormClusterStateImpl(IStateStorage stateStorage,
ILocalAssignmentsBackend assignmentsassignmentsBackend,
ClusterStateContext context,
boolean shouldCloseStateStorageOnDisconnect) |
Modifier and Type | Method and Description |
---|---|
IStateStorage |
WorkerState.getStateStorage() |
Constructor and Description |
---|
WorkerState(Map<String,Object> conf,
IContext mqContext,
String topologyId,
String assignmentId,
Supplier<SupervisorIfaceFactory> supervisorIfaceSupplier,
int port,
String workerId,
Map<String,Object> topologyConf,
IStateStorage stateStorage,
IStormClusterState stormClusterState,
Collection<IAutoCredentials> autoCredentials,
StormMetricRegistry metricRegistry,
Credentials initialCredentials) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.