| 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.
|