Uses of Interface
org.apache.storm.ILocalCluster
Packages that use ILocalCluster
-
Uses of ILocalCluster in org.apache.storm
Subinterfaces of ILocalCluster in org.apache.stormModifier and TypeInterfaceDescriptioninterfaceThis is here mostly for backwards compatibility.Classes in org.apache.storm that implement ILocalClusterModifier and TypeClassDescriptionclassA stand alone storm cluster that runs inside a single process.Methods in org.apache.storm that return ILocalClusterModifier and TypeMethodDescriptionstatic ILocalClusterTesting.getLocalCluster(Map<String, Object> clusterConf) Deprecated.use ``` try (LocalCluster cluster = new LocalCluster.Builder()....build()) { ...Methods in org.apache.storm with parameters of type ILocalClusterModifier and TypeMethodDescriptionstatic voidTesting.advanceClusterTime(ILocalCluster cluster, Integer secs) Simulated time wait for a cluster.static voidTesting.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 TrackedTopologyTesting.mkTrackedTopology(ILocalCluster cluster, StormTopology topology) Deprecated.useTrackedTopologydirectly.static voidTesting.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
Methods in org.apache.storm.testing that return ILocalClusterMethods in org.apache.storm.testing with parameters of type ILocalClusterModifier and TypeMethodDescriptionvoidTestJob.run(ILocalCluster cluster) run the testing logic with the cluster.Constructors in org.apache.storm.testing with parameters of type ILocalClusterModifierConstructorDescriptionTrackedTopology(StormTopology origTopo, ILocalCluster cluster) Create a new topology to be tracked.