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