Uses of Class
org.apache.storm.testing.FixedTuple
Packages that use FixedTuple
-
Uses of FixedTuple in org.apache.storm
Methods in org.apache.storm that return types with arguments of type FixedTupleModifier and TypeMethodDescriptionstatic 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.Method parameters in org.apache.storm with type arguments of type FixedTupleModifier and TypeMethodDescriptionTesting.readTuples
(Map<String, List<FixedTuple>> results, String componentId) Get all of the tuples from a given component on the default stream.Testing.readTuples
(Map<String, List<FixedTuple>> results, String componentId, String streamId) Get all of the tuples from a given component on a given stream. -
Uses of FixedTuple in org.apache.storm.testing
Methods in org.apache.storm.testing that return types with arguments of type FixedTupleModifier and TypeMethodDescriptionTupleCaptureBolt.getAndClearResults()
TupleCaptureBolt.getAndRemoveResults()
MockedSources.getData()
TupleCaptureBolt.getResults()
FixedTupleSpout.getSourceTuples()
Constructor parameters in org.apache.storm.testing with type arguments of type FixedTuple