Package org.apache.storm
package org.apache.storm
-
ClassDescriptionTopology configs are specified as a plain old map.Storm configs are specified as a plain old map.This is a basic example of a Storm topology.Allows a bolt or a spout to be informed when the credentials of the topology have changed.This is here mostly for backwards compatibility.Close this class to kill the topology.This is here mostly for backwards compatibility.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.A stand alone storm cluster that runs inside a single process.Simple way to configure a LocalCluster to meet your needs.A Local way to test DRPC.Launch a sub process and write files out to logs.In local mode,
ProcessSimulatorkeeps track of Shutdownable objects in place of actual processes (in cluster mode).Use this class to submit topologies to run on the Storm cluster.Interface use to track progress of file upload.The timer defined in this file is very similar to java.util.Timer, except it integrates with Storm's time simulation capabilities.A utility that helps with testing topologies, Bolts and Spouts.A topology that has all messages captured and can be read later on.Simply produces a boolean to see if a specific state is true or false.