Uses of Interface
org.apache.storm.state.ISubscribedState

Packages that use ISubscribedState

Package	Description
org.apache.storm.task

Uses of ISubscribedState in org.apache.storm.task

Methods in org.apache.storm.task with type parameters of type ISubscribedState

Modifier and Type	Method and Description
<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.