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 Description static TrackedTopologyTesting. mkTrackedTopology(ILocalCluster cluster, StormTopology topology)Deprecated.useTrackedTopologydirectly.Methods in org.apache.storm that return types with arguments of type TrackedTopology Modifier and Type Method 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 Description ILocalCluster.ILocalTopologyILocalClusterTrackedTopologyAware. submitTopology(String topologyName, Map<String,Object> conf, TrackedTopology topology)Submit a tracked topology to be run in local mode.LocalCluster.LocalTopologyLocalCluster. submitTopology(String topologyName, Map<String,Object> conf, TrackedTopology topology)ILocalCluster.ILocalTopologyILocalClusterTrackedTopologyAware. submitTopologyWithOpts(String topologyName, Map<String,Object> conf, TrackedTopology topology, SubmitOptions submitOpts)Submit a tracked topology to be run in local mode.LocalCluster.LocalTopologyLocalCluster. 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 TrackedTopology Modifier and Type Method Description static 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.
-