Package | Description |
---|---|
org.apache.storm.cluster | |
org.apache.storm.daemon.supervisor | |
org.apache.storm.generated |
Modifier and Type | Method and Description |
---|---|
Assignment |
StormClusterStateImpl.assignmentInfo(String stormId,
Runnable callback) |
Assignment |
IStormClusterState.assignmentInfo(String stormId,
Runnable callback) |
Modifier and Type | Method and Description |
---|---|
VersionedData<Assignment> |
StormClusterStateImpl.assignmentInfoWithVersion(String stormId,
Runnable callback) |
VersionedData<Assignment> |
IStormClusterState.assignmentInfoWithVersion(String stormId,
Runnable callback) |
Modifier and Type | Method and Description |
---|---|
void |
StormClusterStateImpl.setAssignment(String stormId,
Assignment info,
Map<String,Object> topoConf) |
void |
IStormClusterState.setAssignment(String stormId,
Assignment info,
Map<String,Object> topoConf) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,VersionedData<Assignment>> |
ReadClusterState.getAssignmentsSnapshot(IStormClusterState stormClusterState,
List<String> topoIds,
Map<String,VersionedData<Assignment>> localAssignmentVersion,
Runnable callback) |
Modifier and Type | Method and Description |
---|---|
protected Map<Integer,LocalAssignment> |
ReadClusterState.readMyExecutors(String stormId,
String assignmentId,
Assignment assignment) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,VersionedData<Assignment>> |
ReadClusterState.getAssignmentsSnapshot(IStormClusterState stormClusterState,
List<String> topoIds,
Map<String,VersionedData<Assignment>> localAssignmentVersion,
Runnable callback) |
protected Map<Integer,LocalAssignment> |
ReadClusterState.readAssignments(Map<String,VersionedData<Assignment>> assignmentsSnapshot) |
Modifier and Type | Method and Description |
---|---|
Assignment |
Assignment.deepCopy() |
Modifier and Type | Method and Description |
---|---|
int |
Assignment.compareTo(Assignment other) |
boolean |
Assignment.equals(Assignment that) |
Constructor and Description |
---|
Assignment(Assignment other)
Performs a deep copy on other.
|
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.