Uses of Class
org.apache.storm.cluster.VersionedData
-
Packages that use VersionedData Package Description org.apache.storm.cluster org.apache.storm.daemon.worker org.apache.storm.zookeeper -
-
Uses of VersionedData in org.apache.storm.cluster
Methods in org.apache.storm.cluster that return VersionedData Modifier and Type Method Description VersionedData<Assignment>
IStormClusterState. assignmentInfoWithVersion(String stormId, Runnable callback)
VersionedData<Assignment>
StormClusterStateImpl. assignmentInfoWithVersion(String stormId, Runnable callback)
VersionedData<byte[]>
IStateStorage. get_data_with_version(String path, boolean watch)
Get the data at the node along with its version.VersionedData<byte[]>
PaceMakerStateStorage. get_data_with_version(String path, boolean watch)
VersionedData<byte[]>
ZKStateStorage. get_data_with_version(String path, boolean watch)
-
Uses of VersionedData in org.apache.storm.daemon.worker
Methods in org.apache.storm.daemon.worker that return types with arguments of type VersionedData Modifier and Type Method Description AtomicReference<Map<String,VersionedData<Assignment>>>
WorkerState. getAssignmentVersions()
-
Uses of VersionedData in org.apache.storm.zookeeper
Methods in org.apache.storm.zookeeper that return VersionedData Modifier and Type Method 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.
-