Package org.apache.storm.testing
Class MockedSources
- java.lang.Object
-
- org.apache.storm.testing.MockedSources
-
public class MockedSources extends Object
-
-
Constructor Summary
Constructors Constructor Description MockedSources()MockedSources(Map<String,List<FixedTuple>> data)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddMockData(String spoutId, String streamId, Values... valueses)add mock data for the spout.voidaddMockData(String spoutId, Values... valueses)Map<String,List<FixedTuple>>getData()
-
-
-
Constructor Detail
-
MockedSources
public MockedSources()
-
MockedSources
public MockedSources(Map<String,List<FixedTuple>> data)
-
-
Method Detail
-
addMockData
public void addMockData(String spoutId, String streamId, Values... valueses)
add mock data for the spout.- Parameters:
spoutId- the spout to be mockedstreamId- the stream of the spout to be mockedvalueses- the mocked data
-
getData
public Map<String,List<FixedTuple>> getData()
-
-