Uses of Interface
org.apache.storm.ILocalCluster
-
Uses of ILocalCluster in org.apache.storm
Modifier and TypeInterfaceDescriptioninterface
This is here mostly for backwards compatibility.Modifier and TypeClassDescriptionclass
A stand alone storm cluster that runs inside a single process.Modifier and TypeMethodDescriptionstatic ILocalCluster
Testing.getLocalCluster
(Map<String, Object> clusterConf) Deprecated.use ``` try (LocalCluster cluster = new LocalCluster.Builder()....build()) { ... } ```Modifier and TypeMethodDescriptionstatic 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.useTrackedTopology
directly.static void
Testing.simulateWait
(ILocalCluster cluster) If using simulated time simulate waiting for 10 seconds.Testing.trackAndCaptureTopology
(ILocalCluster cluster, StormTopology topology) Track and capture a topology. -
Uses of ILocalCluster in org.apache.storm.testing
Modifier and TypeMethodDescriptionvoid
TestJob.run
(ILocalCluster cluster) run the testing logic with the cluster.ModifierConstructorDescriptionTrackedTopology
(StormTopology origTopo, ILocalCluster cluster) Create a new topology to be tracked.