public class Helper extends Object
| Constructor and Description |
|---|
Helper() |
| Modifier and Type | Method and Description |
|---|---|
static void |
collectMetricsAndKill(String topologyName,
Integer pollInterval,
int duration) |
static int |
getInt(Map map,
Object key,
int def) |
static String |
getStr(Map map,
Object key) |
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.
|
public static void kill(Nimbus.Iface client, String topoName) throws Exception
Exceptionpublic static void collectMetricsAndKill(String topologyName, Integer pollInterval, int duration) throws Exception
Exceptionpublic static void setupShutdownHook(String topoName)
Kill topo on Ctrl-C.
Copyright © 2021 The Apache Software Foundation. All rights reserved.