Uses of Class
org.apache.storm.testing.TrackedTopology
-
Uses of TrackedTopology in org.apache.storm
Modifier and TypeMethodDescriptionstatic TrackedTopology
Testing.mkTrackedTopology
(ILocalCluster cluster, StormTopology topology) Deprecated.Modifier and TypeMethodDescriptionTesting.trackAndCaptureTopology
(ILocalCluster cluster, StormTopology topology) Track and capture a topology.Modifier and TypeMethodDescriptionILocalClusterTrackedTopologyAware.submitTopology
(String topologyName, Map<String, Object> conf, TrackedTopology topology) Submit a tracked topology to be run in local mode.LocalCluster.submitTopology
(String topologyName, Map<String, Object> conf, TrackedTopology topology) ILocalClusterTrackedTopologyAware.submitTopologyWithOpts
(String topologyName, Map<String, Object> conf, TrackedTopology topology, SubmitOptions submitOpts) Submit a tracked topology to be run in local mode.LocalCluster.submitTopologyWithOpts
(String topologyName, Map<String, Object> conf, TrackedTopology topology, SubmitOptions submitOpts) static void
Testing.trackedWait
(TrackedTopology topo) Simulated time wait for a tracked topology.static void
Testing.trackedWait
(TrackedTopology topo, Integer amt) Simulated time wait for a tracked topology.static void
Testing.trackedWait
(TrackedTopology topo, Integer amt, Integer timeoutMs) Simulated time wait for a tracked 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.
TrackedTopology
directly.