Uses of Class
org.apache.storm.Testing.CapturedTopology
-
Uses of Testing.CapturedTopology in org.apache.storm
Modifier and TypeMethodDescriptionTesting.captureTopology
(StormTopology topology) Rewrites a topology so that all the tuples flowing through it are captured.Testing.trackAndCaptureTopology
(ILocalCluster cluster, StormTopology topology) Track and capture a topology.Modifier and TypeMethodDescriptionstatic void
Testing.trackedWait
(Testing.CapturedTopology<TrackedTopology> topo) Simulated time wait for a tracked topology.static void
Testing.trackedWait
(Testing.CapturedTopology<TrackedTopology> topo, Integer amt) Simulated time wait for a tracked topology.static void
Testing.trackedWait
(Testing.CapturedTopology<TrackedTopology> topo, Integer amt, Integer timeoutMs) Simulated time wait for a tracked topology.