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 void
clearState(String id)
static Object
getState(String id)
static Object
globalLock()
static String
registerState(Object init)
static void
setState(String id, Object init)
-