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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RegisteredGlobalState

public RegisteredGlobalState()

Method Details

globalLock

public static Object globalLock()

registerState

public static String registerState(Object init)

setState

public static void setState(String id,
 Object init)

getState

public static Object getState(String id)

clearState

public static void clearState(String id)