Package | Description |
---|---|
org.apache.storm.cluster | |
org.apache.storm.daemon.supervisor | |
org.apache.storm.zookeeper |
Modifier and Type | Method and Description |
---|---|
VersionedData<Assignment> |
StormClusterStateImpl.assignmentInfoWithVersion(String stormId,
Runnable callback) |
VersionedData<Assignment> |
IStormClusterState.assignmentInfoWithVersion(String stormId,
Runnable callback) |
VersionedData<byte[]> |
ZKStateStorage.get_data_with_version(String path,
boolean watch) |
VersionedData<byte[]> |
IStateStorage.get_data_with_version(String path,
boolean watch)
Get the data at the node along with its version.
|
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<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 |
---|---|
static VersionedData<byte[]> |
Zookeeper.getDataWithVersion(org.apache.curator.framework.CuratorFramework zk,
String path,
boolean watch)
Get the data along with a version
|
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.