Uses of Class
org.apache.storm.testing.FixedTuple
-
Uses of FixedTuple in org.apache.storm
Modifier 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.Modifier 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
Modifier and TypeMethodDescriptionTupleCaptureBolt.getAndClearResults()
TupleCaptureBolt.getAndRemoveResults()
MockedSources.getData()
TupleCaptureBolt.getResults()
FixedTupleSpout.getSourceTuples()