Uses of Interface
org.apache.storm.state.ISubscribedState
Packages that use ISubscribedState
- 
Uses of ISubscribedState in org.apache.storm.taskMethods in org.apache.storm.task with type parameters of type ISubscribedStateModifier and TypeMethodDescription<T extends ISubscribedState>
 TTopologyContext.setAllSubscribedState(T obj) All state from all subscribed state spouts streams will be synced with the provided object.<T extends ISubscribedState>
 TTopologyContext.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>
 TTopologyContext.setSubscribedState(String componentId, T obj) Synchronizes the default stream from the specified state spout component id with the provided ISubscribedState object.