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

Modifier and Type	Method	Description
void	addMockData(String spoutId, String streamId, Values... valueses)	add mock data for the spout.
void	addMockData(String spoutId, Values... valueses)
Map<String,List<FixedTuple>>	getData()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 mocked

streamId - the stream of the spout to be mocked

valueses - the mocked data

addMockData

public void addMockData(String spoutId,
                        Values... valueses)

getData

public Map<String,List<FixedTuple>> getData()