Package org.apache.storm.starter
package org.apache.storm.starter
-
ClassesClassDescriptionThis topology is a basic example of doing distributed RPC on top of Storm.This is a basic example of a Storm topology.WordCount but the spout does not stop, and the bolts are implemented in java.This is a basic example of a Storm topology.Some topologies might spawn some threads within bolts to do some work and emit tuples from those threads.An example that demonstrates the usage of
IStatefulWindowedBoltwith window persistence.This is a good example of doing complex Distributed RPC on top of Storm.This topology does a continuous computation of the top N words that the topology has seen in terms of cardinality.Example of using a simple custom join bolt.This topology does a continuous computation of the top N words that the topology has seen in terms of cardinality.Windowing based on tuple timestamp (e.g. the time when tuple is generated rather than when its processed).A sample topology that demonstrates the usage ofIWindowedBoltto calculate sliding window sum.An example topology that demonstrates the use ofIStatefulBoltto manage state.A simple example that demonstrates the usage ofIStatefulWindowedBoltto save the state of the windowing operation to avoid re-computation in case of failures.This topology demonstrates Storm's stream groupings and multilang capabilities.This topology demonstrates Storm's stream groupings and multilang capabilities.