Package org.apache.storm.testing
Class MkClusterParam
java.lang.Object
org.apache.storm.testing.MkClusterParam
The param arg for `Testing.withSimulatedTimeCluster`, `Testing.withTrackedCluster` and `Testing.withLocalCluster`.
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidsetDaemonConf(Map<String, Object> daemonConf) voidsetNimbusDaemon(Boolean nimbusDaemon) When nimbusDaemon is true, the local cluster will be started with a Nimbus Thrift server, allowing communication through for example org.apache.storm.utils.NimbusClient.voidsetPortsPerSupervisor(Integer portsPerSupervisor) voidsetSupervisors(Integer supervisors) 
- 
Constructor Details- 
MkClusterParampublic MkClusterParam()
 
- 
- 
Method Details- 
getSupervisors
- 
setSupervisors
- 
getPortsPerSupervisor
- 
setPortsPerSupervisor
- 
isNimbusDaemon
- 
getDaemonConf
- 
setDaemonConf
- 
setNimbusDaemonWhen nimbusDaemon is true, the local cluster will be started with a Nimbus Thrift server, allowing communication through for example org.apache.storm.utils.NimbusClient.
 
-