Package | Description |
---|---|
org.apache.storm.assignments | |
org.apache.storm.cluster |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryAssignmentBackend
An assignment backend which will keep all assignments and id-info in memory.
|
Modifier and Type | Method and Description |
---|---|
static ILocalAssignmentsBackend |
LocalAssignmentsBackendFactory.getBackend(Map<String,Object> conf) |
static ILocalAssignmentsBackend |
LocalAssignmentsBackendFactory.getDefault() |
Modifier and Type | Method and Description |
---|---|
static IStormClusterState |
ClusterUtils.mkStormClusterState(Object stateStorage,
ILocalAssignmentsBackend backend,
ClusterStateContext context) |
IStormClusterState |
ClusterUtils.mkStormClusterStateImpl(Object stateStorage,
ILocalAssignmentsBackend backend,
ClusterStateContext context) |
Constructor and Description |
---|
StormClusterStateImpl(IStateStorage stateStorage,
ILocalAssignmentsBackend assignmentsassignmentsBackend,
ClusterStateContext context,
boolean shouldCloseStateStorageOnDisconnect) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.