Package | Description |
---|---|
org.apache.storm |
Modifier and Type | Method and Description |
---|---|
static Testing.CapturedTopology<StormTopology> |
Testing.captureTopology(StormTopology topology)
Rewrites a topology so that all the tuples flowing through it are captured
|
static Testing.CapturedTopology<TrackedTopology> |
Testing.trackAndCaptureTopology(ILocalCluster cluster,
StormTopology topology)
Track and capture a topology.
|
Modifier and Type | Method and Description |
---|---|
static 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.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.