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 Summary

Methods inherited from interface org.apache.storm.topology.IStatefulComponent

initState, preCommit, prePrepare, preRollback

Methods inherited from interface org.apache.storm.topology.IWindowedBolt

cleanup, execute, getTimestampExtractor, prepare

Methods inherited from interface org.apache.storm.topology.IComponent

declareOutputFields, getComponentConfiguration