wordCountTopology ERROR:package backtype.storm does not exist
|
louis@louis-VM:~/Downloads/apache-storm-0.9.5/examples/storm-starter/src/jvm/storm/starter$ javac WordCountTopology.javaWordCountTopology.java:20: package backtype.storm does not existimport backtype.storm.Config; ^WordCountTopology.java:21: package backtype.storm does not existimport backtype.storm.LocalCluster; ^WordCountTopology.java:22: package backtype.storm does not existimport backtype.storm.StormSubmitter; ^WordCountTopology.java:23: package backtype.storm.task does not existimport backtype.storm.task.ShellBolt; ^WordCountTopology.java:24: package backtype.storm.topology does not existimport backtype.storm.topology.BasicOutputCollector; ^WordCountTopology.java:25: package backtype.storm.topology does not existimport backtype.storm.topology.IRichBolt; ^WordCountTopology.java:26: package backtype.storm.topology does not existimport backtype.storm.topology.OutputFieldsDeclarer; ^WordCountTopology.java:27: package backtype.storm.topology does not existimport backtype.storm.topology.TopologyBuilder; ^WordCountTopology.java:28: package backtype.storm.topology.base does not existimport backtype.storm.topology.base.BaseBasicBolt; ^WordCountTopology.java:29: package backtype.storm.tuple does not existimport backtype.storm.tuple.Fields; ^WordCountTopology.java:30: package backtype.storm.tuple does not existimport backtype.storm.tuple.Tuple; ^WordCountTopology.java:31: package backtype.storm.tuple does not existimport backtype.storm.tuple.Values; ^WordCountTopology.java:32: package storm.starter.spout does not existimport storm.starter.spout.RandomSentenceSpout; ^WordCountTopology.java:41: cannot find symbolsymbol : class ShellBoltlocation: class storm.starter.WordCountTopology public static class SplitSentence extends ShellBolt implements IRichBolt { ^WordCountTopology.java:41: cannot find symbolsymbol : class IRichBoltlocation: class storm.starter.WordCountTopology public static class SplitSentence extends ShellBolt implements IRichBolt { ^WordCountTopology.java:48: cannot find symbolsymbol : class OutputFieldsDeclarerlocation: class storm.starter.WordCountTopology.SplitSentence public void declareOutputFields(OutputFieldsDeclarer declarer) { ^WordCountTopology.java:58: cannot find symbolsymbol : class BaseBasicBoltlocation: class storm.starter.WordCountTopology public static class WordCount extends BaseBasicBolt { ^WordCountTopology.java:62: cannot find symbolsymbol : class Tuplelocation: class storm.starter.WordCountTopology.WordCount public void execute(Tuple tuple, BasicOutputCollector collector) { ^WordCountTopology.java:62: cannot find symbolsymbol : class BasicOutputCollectorlocation: class storm.starter.WordCountTopology.WordCount public void execute(Tuple tuple, BasicOutputCollector collector) { ^WordCountTopology.java:73: cannot find symbolsymbol : class OutputFieldsDeclarerlocation: class storm.starter.WordCountTopology.WordCount public void declareOutputFields(OutputFieldsDeclarer declarer) { ^WordCountTopology.java:49: cannot find symbolsymbol : class Fieldslocation: class storm.starter.WordCountTopology.SplitSentence declarer.declare(new Fields("word")); ^WordCountTopology.java:47: method does not override or implement a method from a supertype @Override ^WordCountTopology.java:52: method does not override or implement a method from a supertype @Override ^WordCountTopology.java:69: cannot find symbolsymbol : class Valueslocation: class storm.starter.WordCountTopology.WordCount collector.emit(new Values(word, count)); ^WordCountTopology.java:61: method does not override or implement a method from a supertype @Override ^WordCountTopology.java:74: cannot find symbolsymbol : class Fieldslocation: class storm.starter.WordCountTopology.WordCount declarer.declare(new Fields("word", "count")); ^WordCountTopology.java:72: method does not override or implement a method from a supertype @Override ^WordCountTopology.java:86: cannot find symbolsymbol : class TopologyBuilderlocation: class storm.starter.WordCountTopology TopologyBuilder builder = new TopologyBuilder(); ^WordCountTopology.java:86: cannot find symbolsymbol : class TopologyBuilderlocation: class storm.starter.WordCountTopology TopologyBuilder builder = new TopologyBuilder(); ^WordCountTopology.java:88: cannot find symbolsymbol : class RandomSentenceSpoutlocation: class storm.starter.WordCountTopology builder.setSpout("spout", new RandomSentenceSpout(), 5).setNumTasks(7); ^WordCountTopology.java:91: cannot find symbolsymbol : class Fieldslocation: class storm.starter.WordCountTopology builder.setBolt("count", new WordCount(), 12).fieldsGrouping("split", new Fields("word")); ^WordCountTopology.java:93: cannot find symbolsymbol : class Configlocation: class storm.starter.WordCountTopology Config conf = new Config(); ^WordCountTopology.java:93: cannot find symbolsymbol : class Configlocation: class storm.starter.WordCountTopology Config conf = new Config(); ^WordCountTopology.java:100: cannot find symbolsymbol : variable StormSubmitterlocation: class storm.starter.WordCountTopology StormSubmitter.submitTopologyWithProgressBar(args[0], conf, builder.createTopology()); ^WordCountTopology.java:105: cannot find symbolsymbol : class LocalClusterlocation: class storm.starter.WordCountTopology LocalCluster cluster = new LocalCluster(); ^WordCountTopology.java:105: cannot find symbolsymbol : class LocalClusterlocation: class storm.starter.WordCountTopology LocalCluster cluster = new LocalCluster(); ^36 errors何解？ |
免责声明：本内容仅代表回答会员见解不代表天盟观点，请谨慎对待。
版权声明：作者保留权利，不代表天盟立场。
|
|
|
|
|
|
|
|
天盟APP下载
