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 |
StateStorageFactory.mkStore(Map<String,Object> config,
Map<String,Object> authConf,
ClusterStateContext context) |
IStateStorage |
PaceMakerStateStorageFactory.mkStore(Map<String,Object> config,
Map<String,Object> authConf,
ClusterStateContext context) |
static IStormClusterState |
ClusterUtils.mkStormClusterState(Object stateStorage,
ClusterStateContext context) |
static IStormClusterState |
ClusterUtils.mkStormClusterState(Object stateStorage,
ILocalAssignmentsBackend backend,
ClusterStateContext context) |
IStormClusterState |
ClusterUtils.mkStormClusterStateImpl(Object stateStorage,
ILocalAssignmentsBackend backend,
ClusterStateContext context) |