public abstract class BaseRichBolt extends BaseComponent implements IRichBolt
|Constructor and Description|
|Modifier and Type||Method and Description|
Called when an IBolt is going to be shutdown.
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public void cleanup()
Called when an IBolt is going to be shutdown. There is no guarentee that cleanup will be called, because the supervisor kill -9’s worker processes on the cluster.
The one context where cleanup is guaranteed to be called is when a topology is killed when running Storm in local mode.
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.