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 Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic voidclearState(String id) static Objectstatic Objectstatic StringregisterState(Object init) static void
-
Constructor Details
-
RegisteredGlobalState
public RegisteredGlobalState()
-
-
Method Details
-
globalLock
-
registerState
-
setState
-
getState
-
clearState
-