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 © 2022 The Apache Software Foundation. All rights reserved.