Uses of Class
org.apache.storm.testing.TrackedTopology

Packages that use TrackedTopology

Package	Description
org.apache.storm

Uses of TrackedTopology in org.apache.storm

Methods in org.apache.storm that return TrackedTopology

Modifier and Type	Method and Description
static TrackedTopology	Testing.mkTrackedTopology(ILocalCluster cluster, StormTopology topology) Deprecated. use TrackedTopology directly.

Methods in org.apache.storm that return types with arguments of type TrackedTopology

Modifier and Type	Method and Description
static Testing.CapturedTopology<TrackedTopology>	Testing.trackAndCaptureTopology(ILocalCluster cluster, StormTopology topology) Track and capture a topology.

Methods in org.apache.storm with parameters of type TrackedTopology

Modifier and Type	Method and Description
ILocalCluster.ILocalTopology	ILocalClusterTrackedTopologyAware.submitTopology(String topologyName, Map<String,Object> conf, TrackedTopology topology) Submit a tracked topology to be run in local mode.
LocalCluster.LocalTopology	LocalCluster.submitTopology(String topologyName, Map<String,Object> conf, TrackedTopology topology)
ILocalCluster.ILocalTopology	ILocalClusterTrackedTopologyAware.submitTopologyWithOpts(String topologyName, Map<String,Object> conf, TrackedTopology topology, SubmitOptions submitOpts) Submit a tracked topology to be run in local mode.
LocalCluster.LocalTopology	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.

Method parameters in org.apache.storm with type arguments of type TrackedTopology

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.