Package org.apache.storm.perf.utils
Class Helper
java.lang.Object
org.apache.storm.perf.utils.Helper
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic void
collectMetricsAndKill
(String topologyName, Integer pollInterval, int duration) static int
static String
static void
kill
(Nimbus.Iface client, String topoName) static void
runOnClusterAndPrintMetrics
(int durationSec, String topoName, Map<String, Object> topoConf, StormTopology topology) static void
setupShutdownHook
(String topoName) Kill topo on Ctrl-C.
-
Constructor Details
-
Helper
public Helper()
-
-
Method Details
-
kill
- Throws:
Exception
-
getInt
-
getStr
-
collectMetricsAndKill
public static void collectMetricsAndKill(String topologyName, Integer pollInterval, int duration) throws Exception - Throws:
Exception
-
setupShutdownHook
Kill topo on Ctrl-C. -
runOnClusterAndPrintMetrics
public static void runOnClusterAndPrintMetrics(int durationSec, String topoName, Map<String, Object> topoConf, StormTopology topology) throws Exception- Throws:
Exception
-