我是Apache Storm 0.9.5的新手。我正在使用eclipse和maven。 Java版本-1.7。@Override註釋混淆
嘗試1: 我試圖做一個示例代碼和接着在page
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類型必須重寫 超類的方法
和快速的解決辦法是
當我刪除註釋我沒有看到任何錯誤刪除@Override批註
。
正如我們所知,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
。我在第一次嘗試時收到了同樣的錯誤。但其他方法很好。
請原諒我,如果我錯過了一些非常基本的東西!提前致謝。
好像烏爾問題解決了[這裏](http://stackoverflow.com/questions/1678122/must-override-a-superclass-method-errors-after-importing-a -project - 進入 - 文摘)。 – f1sherox
@ f1sherox:非常感謝。爲我工作! – Andy