Package org.apache.storm.topology
Interface IStatefulWindowedBolt<T extends State>
- All Superinterfaces:
- IComponent,- IStatefulComponent<T>,- IWindowedBolt,- Serializable
- All Known Implementing Classes:
- BaseStatefulWindowedBolt
public interface IStatefulWindowedBolt<T extends State>
extends IStatefulComponent<T>, IWindowedBolt
A windowed bolt abstraction for supporting windowing operation with state.
- 
Method SummaryModifier and TypeMethodDescriptiondefault booleanIf the stateful windowed bolt should have its windows persisted in state and maintain a subset of events in memory.default longThe maximum number of window events to keep in memory.Methods inherited from interface org.apache.storm.topology.IComponentdeclareOutputFields, getComponentConfigurationMethods inherited from interface org.apache.storm.topology.IStatefulComponentinitState, preCommit, prePrepare, preRollbackMethods inherited from interface org.apache.storm.topology.IWindowedBoltcleanup, execute, getTimestampExtractor, prepare
- 
Method Details- 
isPersistentdefault boolean isPersistent()If the stateful windowed bolt should have its windows persisted in state and maintain a subset of events in memory.The default is to keep all the window events in memory. - Returns:
- true if the windows should be persisted
 
- 
maxEventsInMemorydefault long maxEventsInMemory()The maximum number of window events to keep in memory.
 
-