org.apache.storm.perf.utils

Class Helper

java.lang.Object

org.apache.storm.perf.utils.Helper

public class Helper
extends Object

Constructor Summary

Constructors

Constructor and Description
Helper()

Method Summary

Modifier and Type	Method and Description
static void	collectLocalMetricsAndKill(org.apache.storm.LocalCluster localCluster, String topologyName, Integer pollInterval, Integer duration, Map clusterConf)
static void	collectMetricsAndKill(String topologyName, Integer pollInterval, Integer duration)
static int	getInt(Map map, Object key, int def)
static String	getStr(Map map, Object key)
static void	kill(Nimbus.Client client, String topoName)
static void	killAndShutdownCluster(org.apache.storm.LocalCluster cluster, String topoName)
static void	runOnClusterAndPrintMetrics(Integer durationSec, String topoName, Map topoConf, StormTopology topology)
static org.apache.storm.LocalCluster	runOnLocalCluster(String topoName, StormTopology topology)
static void	setupShutdownHook(org.apache.storm.LocalCluster cluster, String topoName) Kill topo and Shutdown local cluster on Ctrl-C
static void	setupShutdownHook(String topoName) Kill topo on Ctrl-C

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Helper

public Helper()

Method Detail

kill

public static void kill(Nimbus.Client client,
                        String topoName)
                 throws Exception

Throws:

Exception

killAndShutdownCluster

public static void killAndShutdownCluster(org.apache.storm.LocalCluster cluster,
                                          String topoName)
                                   throws Exception

Throws:

Exception

runOnLocalCluster

public static org.apache.storm.LocalCluster runOnLocalCluster(String topoName,
                                                              StormTopology topology)

getInt

public static int getInt(Map map,
                         Object key,
                         int def)

getStr

public static String getStr(Map map,
                            Object key)

collectMetricsAndKill

public static void collectMetricsAndKill(String topologyName,
                                         Integer pollInterval,
                                         Integer duration)
                                  throws Exception

Throws:

Exception

collectLocalMetricsAndKill

public static void collectLocalMetricsAndKill(org.apache.storm.LocalCluster localCluster,
                                              String topologyName,
                                              Integer pollInterval,
                                              Integer duration,
                                              Map clusterConf)
                                       throws Exception

Throws:

Exception

setupShutdownHook

public static void setupShutdownHook(org.apache.storm.LocalCluster cluster,
                                     String topoName)

Kill topo and Shutdown local cluster on Ctrl-C

setupShutdownHook

public static void setupShutdownHook(String topoName)

Kill topo on Ctrl-C

runOnClusterAndPrintMetrics

public static void runOnClusterAndPrintMetrics(Integer durationSec,
                                               String topoName,
                                               Map topoConf,
                                               StormTopology topology)
                                        throws Exception

Throws:

Exception