Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Abandoned
-
None
-
None
-
None
Description
For raw storm topology, we have backtype.storm.Testing, so can mock a spout like this:
MockedSources mockedSources = new MockedSources();
mockedSources.addMockData("1", new Values("nathan"),
new Values("bob"), new Values("joey"), new Values("nathan"));
the first argument of addMockData is the id of the spout to be mocked, while in trident, the id of spout is not specified by developer, it is auto-generated by trident, so we need utilities to mock spout for trident.