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 and Description |
---|
RegisteredGlobalState() |
Modifier and Type | Method and 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) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.