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 | Description |
---|---|
GroupingType |
The different types of groupings that are supported.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.