| Config |
Topology configs are specified as a plain old map.
|
| Constants |
|
| DaemonConfig |
Storm configs are specified as a plain old map.
|
| ExclamationTopology |
This is a basic example of a Storm topology.
|
| ExclamationTopology.ExclamationBolt |
|
| ExclamationTopology.FixedOrderWordSpout |
|
| LocalCluster |
A stand alone storm cluster that runs inside a single process.
|
| LocalCluster.Builder |
Simple way to configure a LocalCluster to meet your needs.
|
| LocalDRPC |
A Local way to test DRPC.
|
| LogWriter |
Launch a sub process and write files out to logs.
|
| ProcessSimulator |
In local mode, ProcessSimulator keeps track of Shutdownable objects
in place of actual processes (in cluster mode).
|
| ServerConstants |
|
| StormSubmitter |
Use this class to submit topologies to run on the Storm cluster.
|
| StormTimer |
The timer defined in this file is very similar to java.util.Timer, except it integrates with Storm's time simulation capabilities.
|
| StormTimer.QueueEntry |
|
| StormTimer.StormTimerTask |
|
| Testing |
A utility that helps with testing topologies, Bolts and Spouts.
|
| Testing.CapturedTopology<T> |
A topology that has all messages captured and can be read later on.
|
| Thrift |
|
| Thrift.BoltDetails |
|
| Thrift.SpoutDetails |
|