Class CompleteTopologyParam

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

public class CompleteTopologyParam extends Object
The param class for the `Testing.completeTopology`.
  • Constructor Details

    • CompleteTopologyParam

      public CompleteTopologyParam()
  • Method Details

    • getMockedSources

      public MockedSources getMockedSources()
    • setMockedSources

      public void setMockedSources(MockedSources mockedSources)
    • getStormConf

      public Map<String,Object> getStormConf()
    • setStormConf

      public void setStormConf(Map<String,Object> topoConf)
    • getCleanupState

      public boolean getCleanupState()
    • setCleanupState

      public void setCleanupState(Boolean cleanupState)
    • getTopologyName

      public String getTopologyName()
    • setTopologyName

      public void setTopologyName(String topologyName)
    • getTimeoutMs

      public Integer getTimeoutMs()
    • setTimeoutMs

      public void setTimeoutMs(Integer timeoutMs)