Package org.apache.storm.loadgen

Class Summary

Class	Description
CaptureLoad	Capture running topologies for load gen later on.
EstimateThroughput	Estimate the throughput of all topologies.
ExecAndProcessLatencyEngine	A more accurate sleep implementation.
GenLoad	Generate a simulated load.
HttpForwardingMetricsConsumer	Listens for all metrics and POSTs them serialized to a configured URL.
HttpForwardingMetricsServer	A server that can listen for metrics from the HttpForwardingMetricsConsumer.
InputStream	A set of measurements about a stream so we can statistically reproduce it.
InputStream.Builder
LoadBolt	A bolt that simulates a real world bolt based off of statistics about it.
LoadCompConf	Configuration for a simulated spout.
LoadCompConf.Builder
LoadMetricsServer	A metrics server that records and reports metrics for a set of running topologies.
LoadMetricsServer.Measurements
LoadSpout	A spout that simulates a real world spout based off of statistics about it.
NormalDistStats	Stats related to something with a normal distribution, and a way to randomly simulate it.
OutputStream	A set of measurements about a stream so we can statistically reproduce it.
OutputStream.Builder
OutputStreamEngine	Provides an API to simulate the output of a stream.
ScopedTopologySet	A set of topology names that will be killed when this is closed, or when the program exits.
SlowExecutorPattern	A repeating pattern of skewedness in processing times.
ThroughputVsLatency	WordCount but the spout goes at a predefined rate and we collect proper latency statistics.
ThroughputVsLatency.FastRandomSentenceSpout
ThroughputVsLatency.SplitSentence
ThroughputVsLatency.WordCount
TopologyLoadConf	Configuration for a simulated topology.

Enum Summary

Enum	Description
GroupingType	The different types of groupings that are supported.