Name | Description | Type | Package | Framework |
AbstractRankerBolt | This abstract bolt provides the basic behavior of bolts that rank objects according to their count. | Class | storm.starter.bolt | Apache Storm |
BasicDRPCTopology | This topology is a basic example of doing distributed RPC on top of Storm. | Class | storm.starter | Apache Storm |
BasicDRPCTopology .ExclaimBolt | Class | storm.starter.BasicDRPCTopology | Apache Storm | |
ExclamationTopology | This is a basic example of a Storm topology. | Class | storm.starter | Apache Storm |
ExclamationTopology .ExclamationBolt | Class | storm.starter.ExclamationTopology | Apache Storm | |
IntermediateRankingsBolt | This bolt ranks incoming objects by their count. | Class | storm.starter.bolt | Apache Storm |
ManualDRPC | Class | storm.starter | Apache Storm | |
ManualDRPC .ExclamationBolt | Class | storm.starter.ManualDRPC | Apache Storm | |
NthLastModifiedTimeTracker | This class tracks the time-since-last-modify of a "thing" in a rolling fashion. | Class | storm.starter.tools | Apache Storm |
PrinterBolt | Class | storm.starter.bolt | Apache Storm | |
PrintSampleStream | Class | storm.starter | Apache Storm | |
RandomSentenceSpout | Class | storm.starter.spout | Apache Storm | |
Rankable | Note: We do not defensively copy the object wrapped by the Rankable. | Interface | storm.starter.tools | Apache Storm |
RankableObjectWithFields | This class wraps an objects and its associated count, including any additional data fields. | Class | storm.starter.tools | Apache Storm |
Rankings | Class | storm.starter.tools | Apache Storm | |
ReachTopology | This is a good example of doing complex Distributed RPC on top of Storm. | Class | storm.starter | Apache Storm |
ReachTopology .CountAggregator | Class | storm.starter.ReachTopology | Apache Storm | |
ReachTopology .GetFollowers | Class | storm.starter.ReachTopology | Apache Storm | |
ReachTopology .GetTweeters | Class | storm.starter.ReachTopology | Apache Storm | |
ReachTopology .PartialUniquer | Class | storm.starter.ReachTopology | Apache Storm | |
RollingCountAggBolt | This bolt aggregates counts from multiple upstream bolts. | Class | storm.starter.bolt | Apache Storm |
RollingCountBolt | This bolt performs rolling counts of incoming objects, i. | Class | storm.starter.bolt | Apache Storm |
RollingTopWords | This topology does a continuous computation of the top N words that the topology has seen in terms of cardinality. | Class | storm.starter | Apache Storm |
SingleJoinBolt | Class | storm.starter.bolt | Apache Storm | |
SingleJoinExample | Class | storm.starter | Apache Storm | |
SkewedRollingTopWords | This topology does a continuous computation of the top N words that the topology has seen in terms of cardinality. | Class | storm.starter | Apache Storm |
SlidingWindowCounter | This class counts objects in a sliding window fashion. | Class | storm.starter.tools | Apache Storm |
SlotBasedCounter | This class provides per-slot counts of the occurrences of objects. | Class | storm.starter.tools | Apache Storm |
StormRunner | Class | storm.starter.util | Apache Storm | |
TotalRankingsBolt | This bolt merges incoming Rankings. | Class | storm.starter.bolt | Apache Storm |
TransactionalGlobalCount | This is a basic example of a transactional topology. | Class | storm.starter | Apache Storm |
TransactionalGlobalCount .BatchCount | Class | storm.starter.TransactionalGlobalCount | Apache Storm | |
TransactionalGlobalCount .UpdateGlobalCount | Class | storm.starter.TransactionalGlobalCount | Apache Storm | |
TransactionalGlobalCount .Value | Class | storm.starter.TransactionalGlobalCount | Apache Storm | |
TransactionalWords | This class defines a more involved transactional topology then TransactionalGlobalCount. | Class | storm.starter | Apache Storm |
TransactionalWords .BucketCountUpdater | Class | storm.starter.TransactionalWords | Apache Storm | |
TransactionalWords .Bucketize | Class | storm.starter.TransactionalWords | Apache Storm | |
TransactionalWords .BucketValue | Class | storm.starter.TransactionalWords | Apache Storm | |
TransactionalWords .CountValue | Class | storm.starter.TransactionalWords | Apache Storm | |
TransactionalWords .KeyedCountUpdater | Class | storm.starter.TransactionalWords | Apache Storm | |
TridentReach | Class | storm.starter.trident | Apache Storm | |
TridentReach .ExpandList | Class | storm.starter.trident.TridentReach | Apache Storm | |
TridentReach .One | Class | storm.starter.trident.TridentReach | Apache Storm | |
TridentReach .StaticSingleKeyMapState | Class | storm.starter.trident.TridentReach | Apache Storm | |
TridentReach .StaticSingleKeyMapState .Factory | Class | storm.starter.trident.TridentReach.StaticSingleKeyMapState | Apache Storm | |
TridentWordCount | Class | storm.starter.trident | Apache Storm | |
TridentWordCount .Split | Class | storm.starter.trident.TridentWordCount | Apache Storm | |
TupleHelpers | Class | storm.starter.util | Apache Storm | |
TwitterSampleSpout | Class | storm.starter.spout | Apache Storm | |
WordCountTopology | This topology demonstrates Storm's stream groupings and multilang capabilities. | Class | storm.starter | Apache Storm |
WordCountTopology .SplitSentence | Class | storm.starter.WordCountTopology | Apache Storm | |
WordCountTopology .WordCount | Class | storm.starter.WordCountTopology | Apache Storm | |
WordCountTopologyNode | This topology demonstrates Storm's stream groupings and multilang capabilities. | Class | storm.starter | Apache Storm |
WordCountTopologyNode .RandomSentence | Class | storm.starter.WordCountTopologyNode | Apache Storm | |
WordCountTopologyNode .SplitSentence | Class | storm.starter.WordCountTopologyNode | Apache Storm | |
WordCountTopologyNode .WordCount | Class | storm.starter.WordCountTopologyNode | Apache Storm | |