Package org.apache.storm.utils
Class RegisteredGlobalState
- java.lang.Object
-
- org.apache.storm.utils.RegisteredGlobalState
-
public class RegisteredGlobalState extends Object
This class is used as part of testing Storm. It is used to keep track of "global metrics" in an atomic way. For example, it is used for doing fine-grained detection of when a local Storm cluster is idle by tracking the number of transferred tuples vs the number of processed tuples.
-
-
Constructor Summary
Constructors Constructor Description RegisteredGlobalState()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidclearState(String id)static ObjectgetState(String id)static ObjectglobalLock()static StringregisterState(Object init)static voidsetState(String id, Object init)
-