Class 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 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)