本文整理汇总了Java中backtype.storm.generated.KillOptions类的典型用法代码示例。如果您正苦于以下问题:Java KillOptions类的具体用法?Java KillOptions怎么用?Java KillOptions使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
KillOptions类属于backtype.storm.generated包,在下文中一共展示了KillOptions类的17个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: cleanCluster
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
public static void cleanCluster() {
try {
NimbusClient client = getNimbusClient(null);
ClusterSummary clusterSummary = client.getClient().getClusterInfo();
List<TopologySummary> topologySummaries = clusterSummary.get_topologies();
KillOptions killOption = new KillOptions();
killOption.set_wait_secs(1);
for (TopologySummary topologySummary : topologySummaries) {
client.getClient().killTopologyWithOpts(topologySummary.get_name(), killOption);
LOG.info("Successfully kill " + topologySummary.get_name());
}
} catch (Exception e) {
if (client != null) {
client.close();
client = null;
}
LOG.error("Failed to kill all topology ", e);
}
}
开发者ID:alibaba,项目名称:jstorm,代码行数:25,代码来源:JStormHelper.java
示例2: killTopology
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
@Override
public void killTopology(String topologyName) {
try {
// kill topology quickly
KillOptions killOps = new KillOptions();
killOps.set_wait_secs(0);
state.getNimbus().killTopologyWithOpts(topologyName, killOps);
} catch (Exception e) {
LOG.error("fail to kill Topology " + topologyName, e);
}
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:14,代码来源:LocalCluster.java
示例3: killTopologyWithOpts
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
@Override
public void killTopologyWithOpts(String name, KillOptions options)
throws NotAliveException {
try {
state.getNimbus().killTopologyWithOpts(name, options);
} catch (TException e) {
LOG.error("fail to kill Topology " + name, e);
throw new RuntimeException(e);
}
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:13,代码来源:LocalCluster.java
示例4: main
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
/**
* @param args
*/
@SuppressWarnings("rawtypes")
public static void main(String[] args) {
if (args == null || args.length == 0) {
throw new InvalidParameterException("Should input topology name");
}
String topologyName = args[0];
NimbusClient client = null;
try {
Map conf = Utils.readStormConfig();
client = NimbusClient.getConfiguredClient(conf);
if (args.length == 1) {
client.getClient().killTopology(topologyName);
} else {
int delaySeconds = Integer.parseInt(args[1]);
KillOptions options = new KillOptions();
options.set_wait_secs(delaySeconds);
client.getClient().killTopologyWithOpts(topologyName, options);
}
System.out.println("Successfully submit command kill "
+ topologyName);
} catch (Exception e) {
System.out.println(e.getMessage());
e.printStackTrace();
throw new RuntimeException(e);
} finally {
if (client != null) {
client.close();
}
}
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:43,代码来源:kill_topology.java
示例5: killTopology
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
@Override
public void killTopology(String topologyName) {
// TODO Auto-generated method stub
try {
// kill topology quickly
KillOptions killOps = new KillOptions();
killOps.set_wait_secs(0);
state.getNimbus().killTopologyWithOpts(topologyName, killOps);
} catch (Exception e) {
// TODO Auto-generated catch block
LOG.error("fail to kill Topology " + topologyName, e);
}
}
开发者ID:songtk,项目名称:learn_jstorm,代码行数:14,代码来源:LocalCluster.java
示例6: killTopologyWithOpts
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
@Override
public void killTopologyWithOpts(String name, KillOptions options)
throws NotAliveException {
// TODO Auto-generated method stub
try {
state.getNimbus().killTopologyWithOpts(name, options);
} catch (TException e) {
// TODO Auto-generated catch block
LOG.error("fail to kill Topology " + name, e);
throw new RuntimeException(e);
}
}
开发者ID:songtk,项目名称:learn_jstorm,代码行数:13,代码来源:LocalCluster.java
示例7: main
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
if (args == null || args.length == 0) {
throw new InvalidParameterException("Should input topology name");
}
String topologyName = args[0];
NimbusClient client = null;
try {
Map conf = Utils.readStormConfig();
client = NimbusClient.getConfiguredClient(conf);
if (args.length == 1) {
client.getClient().killTopology(topologyName);
} else {
int delaySeconds = Integer.parseInt(args[1]);
KillOptions options = new KillOptions();
options.set_wait_secs(delaySeconds);
client.getClient().killTopologyWithOpts(topologyName, options);
}
System.out.println("Successfully submit command kill "
+ topologyName);
} catch (Exception e) {
System.out.println(e.getMessage());
e.printStackTrace();
throw new RuntimeException(e);
} finally {
if (client != null) {
client.close();
}
}
}
开发者ID:songtk,项目名称:learn_jstorm,代码行数:43,代码来源:kill_topology.java
示例8: main
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
if (args == null || args.length == 0) {
throw new InvalidParameterException("Should input topology name");
}
String topologyName = args[0];
NimbusClient client = null;
try {
Map conf = Utils.readStormConfig();
client = NimbusClient.getConfiguredClient(conf);
if (args.length == 1) {
client.getClient().killTopology(topologyName);
} else {
int delaySeconds = Integer.parseInt(args[1]);
KillOptions options = new KillOptions();
options.set_wait_secs(delaySeconds);
client.getClient().killTopologyWithOpts(topologyName, options);
}
System.out.println("Successfully submit command kill " + topologyName);
} catch (Exception e) {
System.out.println(e.getMessage());
e.printStackTrace();
throw new RuntimeException(e);
} finally {
if (client != null) {
client.close();
}
}
}
开发者ID:kkllwww007,项目名称:jstrom,代码行数:42,代码来源:kill_topology.java
示例9: restart
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
@Override
public void restart(String name, String jsonConf) throws NotAliveException,
InvalidTopologyException, TopologyAssignException, org.apache.thrift7.TException {
String topologyId = null;
// Copy topology files into a tmp dir and copy the new conf.ser to this dir
try {
topologyId = NimbusUtils.findTopoFileInStormdist(data, name);
if (topologyId != null) {
String srcDir = StormConfig.masterStormdistRoot(conf, topologyId);
String destDir = StormConfig.masterStormTmpRoot(conf, name);
FileUtils.copyDirectory(new File(srcDir), new File(destDir));
} else {
String errorInfo = "Topology=" + name + " is not exist!";
throw new InvalidTopologyException(errorInfo);
}
} catch (Exception e) {
LOG.info("InvalidTopologyException: " + e.getMessage());
throw new InvalidTopologyException(e.getMessage());
}
// Restart the topology: Deactivate -> Kill -> Submit
// 1. Deactivate
deactivate(name);
JStormUtils.sleepMs(5000);
// 2. Kill
KillOptions options = new KillOptions();
options.set_wait_secs(1);
killTopologyWithOpts(name, options);
// Wait for supervisors to kill the old topology
int delay = (JStormUtils.parseInt(conf.get(
Config.SUPERVISOR_MONITOR_FREQUENCY_SECS)))*1000 + 5000;
JStormUtils.sleepMs(delay);
// 3. Submit
submitTopologyAfterRestart(name, jsonConf);
}
开发者ID:greeenSY,项目名称:Tstream,代码行数:39,代码来源:ServiceHandler.java
示例10: killTopology
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
public static void killTopology(Map conf, String topologyName) throws Exception {
NimbusClientWrapper client = new NimbusClientWrapper();
try {
Map clusterConf = Utils.readStormConfig();
clusterConf.putAll(conf);
client.init(clusterConf);
KillOptions killOption = new KillOptions();
killOption.set_wait_secs(1);
client.getClient().killTopologyWithOpts(topologyName, killOption);
} finally {
client.cleanup();
}
}
开发者ID:alibaba,项目名称:jstorm,代码行数:14,代码来源:JStormHelper.java
示例11: main
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
public static void main(String[] args) {
if (args == null || args.length == 0) {
throw new InvalidParameterException("Please input topology name");
}
String topologyName = args[0];
NimbusClient client = null;
try {
Map conf = Utils.readStormConfig();
client = NimbusClient.getConfiguredClient(conf);
if (args.length == 1) {
client.getClient().killTopology(topologyName);
} else {
int delaySeconds = Integer.parseInt(args[1]);
KillOptions options = new KillOptions();
options.set_wait_secs(delaySeconds);
client.getClient().killTopologyWithOpts(topologyName, options);
}
System.out.println("Successfully submit command kill " + topologyName);
} catch (Exception e) {
System.out.println(e.getMessage());
e.printStackTrace();
throw new RuntimeException(e);
} finally {
if (client != null) {
client.close();
}
}
}
开发者ID:alibaba,项目名称:jstorm,代码行数:32,代码来源:kill_topology.java
示例12: killTopologyWithOpts
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
void killTopologyWithOpts(String name, KillOptions options)
throws NotAliveException;
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:3,代码来源:ILocalCluster.java
示例13: killTopologyWithOpts
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
@Override
public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, TException {
cluster.killTopologyWithOpts(name, options);
}
开发者ID:QualiMaster,项目名称:Infrastructure,代码行数:5,代码来源:StormUtils.java
示例14: killTopologyWithOpts
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
@Override
public void killTopologyWithOpts(String name, KillOptions options)
throws NotAliveException {
// TODO Auto-generated method stub
}
开发者ID:IntersysConsulting,项目名称:ingestive,代码行数:7,代码来源:MockedLocalCluster.java
示例15: killTopology
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
/**
* kill topology
*
* @param topologyname
* String topology name
*/
@Override
public void killTopology(String name) throws NotAliveException, TException {
killTopologyWithOpts(name, new KillOptions());
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:12,代码来源:ServiceHandler.java
示例16: killTopology
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
/**
* kill a topology
*
* @param topologyName topology name
*/
@Override
public void killTopology(String topologyName) throws TException {
killTopologyWithOpts(topologyName, new KillOptions());
}
开发者ID:alibaba,项目名称:jstorm,代码行数:10,代码来源:ServiceHandler.java
示例17: killTopologyWithOpts
import backtype.storm.generated.KillOptions; //导入依赖的package包/类
void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException;
开发者ID:kkllwww007,项目名称:jstrom,代码行数:2,代码来源:ILocalCluster.java
注:本文中的backtype.storm.generated.KillOptions类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论