Package | Description |
---|---|
backtype.storm.task |
Modifier and Type | Method and Description |
---|---|
<T extends ISubscribedState> |
TopologyContext.setAllSubscribedState(T obj)
All state from all subscribed state spouts streams will be synced with
the provided object.
|
<T extends ISubscribedState> |
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> |
TopologyContext.setSubscribedState(String componentId,
T obj)
Synchronizes the default stream from the specified state spout component
id with the provided ISubscribedState object.
|
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.