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

Method run

storm-server/src/main/java/org/apache/storm/testing/TestJob.java:37–37  ·  view source on GitHub ↗

run the testing logic with the cluster. @param cluster the cluster which created by Testing.withSimulatedTimeLocalCluster and Testing.withTrackedCluster .

(ILocalCluster cluster)

Source from the content-addressed store, hash-verified

35 * and <code>Testing.withTrackedCluster</code>.
36 */
37 void run(ILocalCluster cluster) throws Exception;
38}

Callers 8

whileTimeoutMethod · 0.65
withSimulatedTimeMethod · 0.65
withLocalClusterMethod · 0.65
withTrackedClusterMethod · 0.65
executeMethod · 0.65
runMethod · 0.65
runMethod · 0.65

Implementers 15

ScheduleRunnablestorm-client/test/jvm/org/apache/storm
JCQueueTeststorm-client/test/jvm/org/apache/storm
IncProducerstorm-client/test/jvm/org/apache/storm
ConsumerThdstorm-client/test/jvm/org/apache/storm
ExecutorTransferMultiThreadingTeststorm-client/test/jvm/org/apache/storm
StormTimerstorm-client/src/jvm/org/apache/storm/
StormTimerTaskstorm-client/src/jvm/org/apache/storm/
LogWriterstorm-client/src/jvm/org/apache/storm/
TimeTriggerPolicystorm-client/src/jvm/org/apache/storm/
WaterMarkEventGeneratorstorm-client/src/jvm/org/apache/storm/
SpoutHeartbeatTimerTaskstorm-client/src/jvm/org/apache/storm/
Utilsstorm-client/src/jvm/org/apache/storm/

Calls

no outgoing calls

Tested by 6

whileTimeoutMethod · 0.52
withSimulatedTimeMethod · 0.52
withLocalClusterMethod · 0.52
withTrackedClusterMethod · 0.52
executeMethod · 0.52