<T extends ISubscribedState>
T |
TopologyContext.setAllSubscribedState(T obj) |
All state from all subscribed state spouts streams will be synced with the provided object.
|
<T extends ISubscribedState>
T |
TopologyContext.setSubscribedState(String componentId,
String streamId,
T obj) |
Synchronizes the specified stream from the specified state spout component id with the provided ISubscribedState object.
|
<T extends ISubscribedState>
T |
TopologyContext.setSubscribedState(String componentId,
T obj) |
Synchronizes the default stream from the specified state spout component id with the provided ISubscribedState object.
|