Package | Description |
---|---|
org.apache.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 © 2023 The Apache Software Foundation. All rights reserved.