Uses of Interface
org.apache.storm.state.ISubscribedState
-
Uses of ISubscribedState in org.apache.storm.task
Modifier 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.