ClassDescriptionBase class that abstracts the common logic for executing bolts in a stateful topology.BoltDeclarer includes grouping APIs for storm topology.Wraps
IRichBoltand forwards checkpoint tuples in a stateful topology.Extensions of this class takes a reference to one or more configuration files.Common methods for all possible components in a topology.A bolt abstraction for supporting stateful computation.Common methods for stateful components in the topology.A windowed bolt abstraction for supporting windowing operation with state.A bolt abstraction for supporting time and count based sliding & tumbling windows.This is a new base interface that can be used by anything that wants to mirror RAS's basic API.A request for a shared memory region off heap between workers on a node.A request for a shared memory region off heap, but only within a worker.A request for a shared memory region on heap.Wraps a
IStatefulBoltand manages the state of the bolt.TopologyBuilder exposes the Java API for specifying a topology for Storm to execute.A
TimestampExtractorthat extracts timestamp from a specific field in the tuple.An
IWindowedBoltwrapper that does the windowing of tuples.