| Package | Description |
|---|---|
| org.apache.storm.cluster | |
| org.apache.storm.daemon.worker | |
| 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[]> |
PaceMakerStateStorage.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 |
|---|---|
AtomicReference<Map<String,VersionedData<Assignment>>> |
WorkerState.getAssignmentVersions() |
| Modifier and Type | Method and Description |
|---|---|
static VersionedData<byte[]> |
ClientZookeeper.getDataWithVersion(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk,
String path,
boolean watch)
Get the data along with a version.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.