Uses of Interface
org.apache.storm.ILocalCluster

Packages that use ILocalCluster

Package	Description
org.apache.storm
org.apache.storm.testing

Uses of ILocalCluster in org.apache.storm

Subinterfaces of ILocalCluster in org.apache.storm

Modifier and Type	Interface and Description
interface	ILocalClusterTrackedTopologyAware This is here mostly for backwards compatibility.

Classes in org.apache.storm that implement ILocalCluster

Modifier and Type	Class and Description
class	LocalCluster A stand alone storm cluster that runs inside a single process.

Methods in org.apache.storm that return ILocalCluster

Modifier and Type	Method and Description
static ILocalCluster	Testing.getLocalCluster(Map<String,Object> clusterConf) Deprecated. use try (LocalCluster cluster = new LocalCluster.Builder()....build()) { ... }

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

Modifier and Type	Method and Description
static void	Testing.advanceClusterTime(ILocalCluster cluster, Integer secs) Simulated time wait for a cluster.
static void	Testing.advanceClusterTime(ILocalCluster cluster, Integer secs, Integer step) Simulated time wait for a cluster.
static Map<String,List<FixedTuple>>	Testing.completeTopology(ILocalCluster cluster, StormTopology topology) Run a topology to completion capturing all of the messages that are emitted.
static Map<String,List<FixedTuple>>	Testing.completeTopology(ILocalCluster cluster, StormTopology topology, CompleteTopologyParam param) Run a topology to completion capturing all of the messages that are emitted.
static TrackedTopology	Testing.mkTrackedTopology(ILocalCluster cluster, StormTopology topology) Deprecated. use TrackedTopology directly.
static void	Testing.simulateWait(ILocalCluster cluster) If using simulated time simulate waiting for 10 seconds.
static Testing.CapturedTopology<TrackedTopology>	Testing.trackAndCaptureTopology(ILocalCluster cluster, StormTopology topology) Track and capture a topology.

Uses of ILocalCluster in org.apache.storm.testing

Methods in org.apache.storm.testing that return ILocalCluster

Modifier and Type	Method and Description
ILocalCluster	TrackedTopology.getCluster()

Methods in org.apache.storm.testing with parameters of type ILocalCluster

Modifier and Type	Method and Description
void	TestJob.run(ILocalCluster cluster) run the testing logic with the cluster.

Constructors in org.apache.storm.testing with parameters of type ILocalCluster

Constructor and Description
TrackedTopology(StormTopology origTopo, ILocalCluster cluster) Create a new topology to be tracked.