Package org.apache.storm.topology
package org.apache.storm.topology
-
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.InputDeclarer<T extends InputDeclarer>When writing topologies using Java,IRichBoltandIRichSpoutare the main interfaces to use to implement components of the topology.When writing topologies using Java,IRichBoltandIRichSpoutare the main interfaces to use to implement components of the topology.IStatefulBolt<T extends State>A bolt abstraction for supporting stateful computation.IStatefulComponent<T extends State>Common methods for stateful components in the topology.IStatefulWindowedBolt<T extends State>A windowed bolt abstraction for supporting windowing operation with state.A bolt abstraction for supporting time and count based sliding & tumbling windows.PersistentWindowedBoltExecutor<T extends State>Wraps aIStatefulWindowedBoltand handles the execution.ResourceDeclarer<T extends ResourceDeclarer>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.StatefulBoltExecutor<T extends State>Wraps aIStatefulBoltand manages the state of the bolt.StatefulWindowedBoltExecutor<T extends State>Wraps aIStatefulWindowedBoltand handles the execution.TopologyBuilder exposes the Java API for specifying a topology for Storm to execute.ATimestampExtractorthat extracts timestamp from a specific field in the tuple.AnIWindowedBoltwrapper that does the windowing of tuples.