Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.testing |
Class and Description |
---|
CompleteTopologyParam
The param class for the `Testing.completeTopology`.
|
FixedTuple |
MkClusterParam
The param arg for `Testing.withSimulatedTimeCluster`, `Testing.withTrackedCluster` and `Testing.withLocalCluster`.
|
MkTupleParam |
TestJob
This is the core interface for the storm java testing, usually
we put our java unit testing logic in the run method.
|
TrackedTopology
A tracked topology keeps metrics for every bolt and spout.
|
TupleCaptureBolt |
Class and Description |
---|
AckFailDelegate |
CompletableSpout |
FixedTuple |
MockedSources |
NonRichBoltTracker |
TestWordCounter |
Copyright © 2023 The Apache Software Foundation. All rights reserved.