| 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 © 2019 The Apache Software Foundation. All rights reserved.