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 © 2019 The Apache Software Foundation. All rights reserved.