したがって、線形のトポロジがあります。ボルト2がjaxb解析を実行し、何らかの理由でxmlを解析できないとしましょう。ボルト3または4に移動させたくありません。プロセスを停止したいだけです。
プロセスを停止するにはどうすればよいですか？
何も放出せずに、入ってくるタプルを確認するだけです。
public void execute(Tuple tuple) {
try {
// process tuple here
collector.emit("your_stream",tuple,new Values(value));
} catch(Execption e) {
// don't emit
} finally {
collector.ack(tuple);
}
}
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加