与@Override注释混淆



我是Apache Storm 0.9.5的新手。我在maven中使用eclipse。Java版本1.7。

尝试1:我正在尝试做一个示例代码,并遵循页面中给出的说明

import java.util.*;
//import storm tuple packages
import backtype.storm.tuple.Fields;
import backtype.storm.tuple.Values;
//import Spout interface packages
import backtype.storm.topology.IRichSpout;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.spout.SpoutOutputCollector;
import backtype.storm.task.TopologyContext;
//Create a class FakeLogReaderSpout which implement IRichSpout interface 
   to access functionalities
public class FakeCallLogReaderSpout implements IRichSpout {
   //Create instance for SpoutOutputCollector which passes tuples to bolt.
   private SpoutOutputCollector collector;
   private boolean completed = false;
   //Create instance for TopologyContext which contains topology data.
   private TopologyContext context;
   //Create instance for Random class.
   private Random randomGenerator = new Random();
   private Integer idx = 0;
   @Override
   public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
      this.context = context;
      this.collector = collector;
   }
   @Override
   public void nextTuple() {
      if(this.idx <= 1000) {
         List<String> mobileNumbers = new ArrayList<String>();
         mobileNumbers.add("1234123401");
         mobileNumbers.add("1234123402");
         mobileNumbers.add("1234123403");
         mobileNumbers.add("1234123404");
         Integer localIdx = 0;
         while(localIdx++ < 100 && this.idx++ < 1000) {
            String fromMobileNumber = mobileNumbers.get(randomGenerator.nextInt(4));
            String toMobileNumber = mobileNumbers.get(randomGenerator.nextInt(4));
            while(fromMobileNumber == toMobileNumber) {
               toMobileNumber = mobileNumbers.get(randomGenerator.nextInt(4));
            }
            Integer duration = randomGenerator.nextInt(60);
            this.collector.emit(new Values(fromMobileNumber, toMobileNumber, duration));
         }
      }
   }
   @Override
   public void declareOutputFields(OutputFieldsDeclarer declarer) {
      declarer.declare(new Fields("from", "to", "duration"));
   }
   //Override all the interface methods
   @Override
   public void close() {}
   public boolean isDistributed() {
      return false;
   }
   @Override
   public void activate() {}
   @Override 
   public void deactivate() {}
   @Override
   public void ack(Object msgId) {}
   @Override
   public void fail(Object msgId) {}
   @Override
   public Map<String, Object> getComponentConfiguration() {
      return null;
   }
}

我收到的错误信息如下

CallLogCreatorBolt类型的方法cleanup()必须重写超类方法

快速解决方案是

删除@覆盖注释

当我删除注释时,我没有看到任何错误。

正如我们所知,IRichBolt API有一个名为cleanup()的方法,该方法具有相同的参数。我的类CallLogCreatorBolt的想法是覆盖IRichBolt类中存在的cleanup()

1.我的问题是我使用@Override时出现了什么问题

尝试2:我删除了类CallLogCreatorBolt中的所有方法。然后我点击eclipse提供的Add unimplemented methods选项。

public class CallLogCreatorBolt implements IRichBolt {
    public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
        // TODO Auto-generated method stub
    }
    public void execute(Tuple input) {
        // TODO Auto-generated method stub
    }
    @Override
    public void cleanup() {
        // TODO Auto-generated method stub
    }
    public void declareOutputFields(OutputFieldsDeclarer declarer) {
        // TODO Auto-generated method stub
    }
    public Map<String, Object> getComponentConfiguration() {
        // TODO Auto-generated method stub
        return null;
    }
}

如果您注意到,我已经为cleanup()方法单独添加了@Override。我得到的错误与我第一次尝试时收到的错误相同。但其他方法也可以。

如果我错过了一些非常基本的东西,请原谅我!提前谢谢。

感谢@f1sherox

问题出在JRE版本上。该项目在JRE1.5中执行。但理想情况下,它应该至少是1.6。

修复如下:

右键单击项目资源管理器/导航器面板中的项目-->选择属性-->Java构建路径-->在JRE系统库上选择[JAVASE-1.5]-->单击编辑按钮-->选择所需的适当JRE版本[I choose version-1.7]-->完成-->应用并确定。

我们完成了:)

最新更新