backtype.storm.testing

Class MockedSources

java.lang.Object

backtype.storm.testing.MockedSources

public class MockedSources
extends Object

Constructor Summary

Constructors

Constructor and Description
MockedSources()

Method Summary

Methods

Modifier and Type	Method and 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()

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

objects - the mocked data

addMockData

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

getData

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