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 | |
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 | |
SpoutTracker | |
TestAggregatesCounter | |
TestConfBolt | |
TestEventLogSpout | |
TestEventOrderCheckBolt | |
TestGlobalCount | |
TestKryoDecorator | |
TestPlannerBolt | |
TestPlannerSpout | |
TestSerObject | |
TestWordCounter | |
TestWordSpout | |
TrackedTopology | |
TupleCaptureBolt |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.