Package org.apache.storm.utils
Class RegisteredGlobalState
java.lang.Object
org.apache.storm.utils.RegisteredGlobalState
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 SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic voidclearState(String id) static Objectstatic Objectstatic StringregisterState(Object init) static void
- 
Constructor Details- 
RegisteredGlobalStatepublic RegisteredGlobalState()
 
- 
- 
Method Details- 
globalLock
- 
registerState
- 
setState
- 
getState
- 
clearState
 
-