| Interface | Description |
|---|---|
| ICredentialsListener |
Allows a bolt or a spout to be informed when the credentials of the topology have changed.
|
| ILocalCluster |
This is here mostly for backwards compatibility.
|
| ILocalCluster.ILocalTopology |
Close this class to kill the topology.
|
| ILocalClusterTrackedTopologyAware |
This is here mostly for backwards compatibility.
|
| ILocalDRPC | |
| ISubmitterHook |
if FQCN of an implementation of this class is specified by setting the config storm.topology.submission.notifier.plugin.class, that class’s notify method will be invoked when a topology is successfully submitted via StormSubmitter class.
|
| StormSubmitter.ProgressListener |
Interface use to track progress of file upload.
|
| Testing.Condition |
Simply produces a boolean to see if a specific state is true or false.
|
| Class | Description |
|---|---|
| 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 |
Copyright © 2021 The Apache Software Foundation. All rights reserved.