Package org.apache.storm.testing
Class TrackedTopology
java.lang.Object
org.apache.storm.testing.TrackedTopology
A tracked topology keeps metrics for every bolt and spout.
 This allows a test to know how many tuples have been fully processed.
 Metrics are tracked on a per cluster basis.  So only one tracked topology
 should be run in a tracked cluster to avoid conflicts.
- 
Constructor SummaryConstructorsConstructorDescriptionTrackedTopology(StormTopology origTopo, ILocalCluster cluster) Create a new topology to be tracked.
- 
Method SummaryModifier and TypeMethodDescriptionintRead a metric from the tracked cluster (NOT JUST THIS TOPOLOGY).voidWait for 1 tuple to be fully processed.voidtrackedWait(int amt) Wait for amt tuples to be fully processed.voidtrackedWait(int amt, int timeoutMs) Wait for amt tuples to be fully processed timeoutMs happens.
- 
Constructor Details- 
TrackedTopologyCreate a new topology to be tracked.- Parameters:
- origTopo- the original topology.
- cluster- a cluster that should have been launched with tracking enabled.
 
 
- 
- 
Method Details- 
getTopology
- 
getCluster
- 
trackedWaitpublic void trackedWait()Wait for 1 tuple to be fully processed.
- 
trackedWaitpublic void trackedWait(int amt) Wait for amt tuples to be fully processed.
- 
trackedWaitpublic void trackedWait(int amt, int timeoutMs) Wait for amt tuples to be fully processed timeoutMs happens.
- 
globalAmtRead a metric from the tracked cluster (NOT JUST THIS TOPOLOGY).- Parameters:
- key- one of "spout-emitted", "processed", or "transferred"
- Returns:
- the amount of that metric
 
 
-