MCPcopy Create free account
hub / github.com/apache/storm / trackedWait

Method trackedWait

storm-server/src/main/java/org/apache/storm/Testing.java:534–536  ·  view source on GitHub ↗

Simulated time wait for a tracked topology. This is intended for internal testing.

(CapturedTopology<TrackedTopology> topo)

Source from the content-addressed store, hash-verified

532 * Simulated time wait for a tracked topology. This is intended for internal testing.
533 */
534 public static void trackedWait(CapturedTopology<TrackedTopology> topo) {
535 topo.topology.trackedWait();
536 }
537
538 /**
539 * Simulated time wait for a tracked topology. This is intended for internal testing.

Callers 4

testWithTrackedClusterMethod · 0.95
testAckingMethod · 0.95
testAckBranchingMethod · 0.95
testAckingSelfAnchorMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected