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 Detail

      • RegisteredGlobalState

        public RegisteredGlobalState()
    • Method Detail

      • globalLock

        public static Object globalLock()
      • registerState

        public static String registerState​(Object init)
      • setState

        public static void setState​(String id,
                                    Object init)
      • clearState

        public static void clearState​(String id)