| Interface | Description |
|---|---|
| AckFailDelegate | |
| TestJob |
This is the core interface for the storm java testing, usually
we put our java unit testing logic in the run method.
|
| Class | Description |
|---|---|
| AckFailMapTracker | |
| AckTracker | |
| BatchNumberList | |
| BatchProcessWord | |
| BatchRepeatA | |
| BoltTracker | |
| CompleteTopologyParam |
The param class for the
Testing.completeTopology. |
| CountingBatchBolt | |
| CountingCommitBolt | |
| FeederSpout | |
| FixedTuple | |
| FixedTupleSpout | |
| ForwardingMetricsConsumer | |
| IdentityBolt | |
| KeyedCountingBatchBolt | |
| KeyedCountingCommitterBolt | |
| KeyedSummingBatchBolt | |
| MemoryTransactionalSpout | |
| MemoryTransactionalSpoutMeta | |
| MkClusterParam |
The param arg for
Testing.withSimulatedTimeCluster and Testing.withTrackedCluster |
| MkTupleParam | |
| MockedSources | |
| NGrouping | |
| NonRichBoltTracker | |
| OpaqueMemoryTransactionalSpout |
This spout only works in local mode.
|
| PrepareBatchBolt | |
| PythonShellMetricsBolt | |
| PythonShellMetricsSpout | |
| SingleUserSimpleTransport | |
| SpoutTracker | |
| TestAggregatesCounter | |
| TestConfBolt | |
| TestEventLogSpout | |
| TestEventOrderCheckBolt | |
| TestGlobalCount | |
| TestKryoDecorator | |
| TestPlannerBolt | |
| TestPlannerSpout | |
| TestSerObject | |
| TestWordCounter | |
| TestWordSpout | |
| TrackedTopology | |
| TupleCaptureBolt |
Copyright © 2015. All rights reserved.