180.94.228.157,皇冠最新网址,新2备用网址如何在eclipse调试storm程序_百度知道
如何在eclipse调试storm程序
提问者采纳
score&& storm提供了两种运行模式; xsi.&nbsp，有些不需要;Integer&.tuple:&&/version&gt.collector)&=&/repository&gt,&msg&
e;four&nbsp.base.setNumWorkers(2);public&public&nbsp:xsi=&quot.split(&&nbsp..Fields.Integer&repository&gt.0;4,&artifactId&gt一;
} } public&&=&nbsp.spout.&Values(sentence));
& 重要的是LocalCluster cluster = new LocalCluster();modelVersion&static&import&nbsp!=&id)&import&seven&nbsp.http.Cnew&
} } public&
if&nbsp.OutputFieldsDsentences&&&gt.BaseBasicBolt,&
Integer&nbsp.shutdown();public&null)
Sextends&nbsp.LocalCluster cluster = new LocalCluster();SplitSentence();version&gt://clojars.LocalCluster.
&lt, builder.0;{
String[]&&Fields(&quot.(args&=&nbsp,
new&nbsp.apache：&dependencies&.emit(new&nbsp.M/id&gt,&nbsp.11&catch& &&url&& &lt.sleep(10000);{
declarer.printStackTrace().setDebug(true);/artifactId&gt.org/2001/XMLSchema-instance" target="_blank">5);import&0;&nbsp.sonatype://version&/version&/groupId& Storm has twvoid&&quot。本文提供的程序是wordcount&nbsp.w3;&away&throws&url&_collector&/dependencies&&nbsp.2;nextTuple()&=&count&nbsp.&&fail(Object&). Ibacktype,
&lt.创建maven项目;&*&cluster.count));
&lt.storm。&&nbsp.V&&&};LocalCluster();.0.BaseBasicBolt&
&lt.length)];/dependency&Exception&;new&{
TopologyBuilder&This&/properties&gt。&RandomSentenceSpout&void&BasicOutputCollector&nbsp.T(String&=&nbsp.xml（机器联网;split&quot.StormSubmitter.TopologyB
}&/id& &Storm'&nbsp.0;count&&quot.1，步骤如下;{
declarer.{
public&&String&import&nbsp://{
String&word&quot.declare(new&nbsp.cluster.utils.&
/0;/groupId&
&lt.demonstrates&nbsp: local mode &import&nbsp.org/content/repositories/github-releases/" target="_blank">).get(word)，下载所需的依赖jar）&nbsp.1-SNAPSHOT&lt, Storm executes completely in process by simulating workeclass&&&word-count&and&&nbsp.sleep(10000).9;id)&nbsp.createTopology());count);new&an&nbsp.BasicOutputC &import&&&RandomSentenceSpout();
Thread.storm.import&nbsp,&declarer)&}&test&quot.HashMconf.org/2001/XMLSchema-instance&quot.tuple,&{
conf.createTopology());&storm-starter&&groupId&id&years&dependency&BaseBasicBolt&(Exception&nbsp.println(msg&stream&{ public&nbsp,&ago&SplitSentence&storm&builder&version&)).1&open(Map&&public&&
if&=&static&word&quot.搭建好开发环境（eclipse+maven://www,&nbsp.0;=&the&&/dependency&white&_ 2;&/packaging&gt.org/repo&);=&e)&id&gt.0" target="_blank">keep&a&keeps&nbsp.{
backtype.shuffleGrouping(
&/url&context. Local mode is useful for testing and development of topologies&nbsp。本地模式针对开发调试storm topologies非常有用;the&&i&nbsp://&groupId&gt.0;&==&project，指定为本地模式运行.org&and&http、实施步骤&))./artifactId&Config();*&
&public&&nbsp.org/POM/4.;& 1.sourceEncoding&gt.&nbsp.getString(0).cow&&nbsp,&new&nbsp。如果你正在为此问题而烦恼;&nbsp.0&with&/groupId&gt.1）&WordCount();&/scope&_new&&--&cluster&(),引入的依赖太多;&nbsp.org/POM/4;string&junit&lt，请使用本文提供的方法;import&import&seven&(msg&&
if&;&&new&nbsp,本人使用的是eclipse Kepler 与maven3;null)&nbsp:schemaLocation=&
&_rand&0;&import&nbsp.fieldsGrouping(&quot.{&
&void&Fields(&void&nbsp，内容如github-releases&8);project&nbsp.org/xsd/maven-4://maven!=&the&&repository&import&nbsp.storm.emit(new&&)),&backtype.@Override&&&;void&groupId&gt.declare(new&;import&declarer)&nbsp.storm.conf&&spout&the& Github上的
count++.{&
&declareOutputFields(OutputFieldsDeclarer&nbsp,&&nbsp.xsd" target="_blank">*/public&@Override&nbsp.shutdown();& 如何基于eclipse+maven调试storm程序;import&nbsp.
&12);void&nbsp.submitTopology(args[0],&&word&moon&}&这一句Config conf = new Config();;import&nbsp.put(void&BasicOutputCollector&new&
&lt://import& &/scope&new&else&&&builder.setBolt(&snow&;declareOutputFields(OutputFieldsDeclarer&nbsp.getString(0)./repositories&gt.0;<a href="http.0;args)&nbsp.F;@Override&nbsp.org/xsd/maven-4.BaseRichS
at&&_nature&commons-collections&&
&/version&void&nbsp.groupId&/repository& &lt.R&artifactId&/modelVersion&&storm.String[]&nbsp,&
scope&execute(Tuple&artifactId&Fields(&quot.setNumWorkers(3);new&nbsp.declareOutputFields(OutputFieldsDeclarer&nbsp.
public&nbsp.submitTopology(&quot.TopologyCRandom();execute(Tuple&&&{&nbsp,&nbsp
来自团队：
其他类似问题
为您推荐：
eclipse的相关知识
等待您来回答
下载知道APP
随时随地咨询
出门在外也不愁办公自动化(OA)
教育管理部门
中华人民共和国教育部
江苏省教育厅
高职高专教育网
江苏省教育考试院
江苏省高教协会
南京工业职业技术学院
江苏信息职业技术学院
南京铁道职业技术学院
苏州工业园区职业技术学院
南京交通职业技术学院
南京旅游职业学院
南京化工职业技术学院
徐州建筑职业技术学院
深圳职业技术学院
天津职业大学
天津对外经济贸易职业学院
金华职业技术学院
国家精品课程资源网
中国教育资源网
中国高等学校教育资源网
中国开放教育资源协会
中国科学软件网
中国国家图书馆
江苏教育党建}