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
Exception
public static void collectMetricsAndKill(String topologyName, Integer pollInterval, int duration) throws Exception
Exception
public static void setupShutdownHook(String topoName)
Kill topo on Ctrl-C.
Copyright © 2022 The Apache Software Foundation. All rights reserved.