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 Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
setDaemonConf
(Map<String, Object> daemonConf) void
setNimbusDaemon
(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.void
setPortsPerSupervisor
(Integer portsPerSupervisor) void
setSupervisors
(Integer supervisors)
-
Constructor Details
-
MkClusterParam
public MkClusterParam()
-
-
Method Details
-
getSupervisors
-
setSupervisors
-
getPortsPerSupervisor
-
setPortsPerSupervisor
-
isNimbusDaemon
-
getDaemonConf
-
setDaemonConf
-
setNimbusDaemon
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.
-