Uses of Class
org.apache.storm.testing.TrackedTopology
Packages that use TrackedTopology
-
Uses of TrackedTopology in org.apache.storm
Methods in org.apache.storm that return TrackedTopologyModifier and TypeMethodDescriptionstatic TrackedTopologyTesting.mkTrackedTopology(ILocalCluster cluster, StormTopology topology) Deprecated.Methods in org.apache.storm that return types with arguments of type TrackedTopologyModifier and TypeMethodDescriptionTesting.trackAndCaptureTopology(ILocalCluster cluster, StormTopology topology) Track and capture a topology.Methods in org.apache.storm with parameters of type TrackedTopologyModifier 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 voidTesting.trackedWait(TrackedTopology topo) Simulated time wait for a tracked topology.static voidTesting.trackedWait(TrackedTopology topo, Integer amt) Simulated time wait for a tracked topology.static voidTesting.trackedWait(TrackedTopology topo, Integer amt, Integer timeoutMs) Simulated time wait for a tracked topology.Method parameters in org.apache.storm with type arguments of type TrackedTopologyModifier and TypeMethodDescriptionstatic voidTesting.trackedWait(Testing.CapturedTopology<TrackedTopology> topo) Simulated time wait for a tracked topology.static voidTesting.trackedWait(Testing.CapturedTopology<TrackedTopology> topo, Integer amt) Simulated time wait for a tracked topology.static voidTesting.trackedWait(Testing.CapturedTopology<TrackedTopology> topo, Integer amt, Integer timeoutMs) Simulated time wait for a tracked topology.
TrackedTopologydirectly.