Class MockedSources

java.lang.Object
org.apache.storm.testing.MockedSources

public class MockedSources extends Object
  • Constructor Details

  • Method Details

    • 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()