Class ConfigurableTopology

java.lang.Object
org.apache.storm.topology.ConfigurableTopology
Direct Known Subclasses:
AnchoredWordCount, ExclamationTopology, LambdaTopology, MultiThreadWordCountTopology, RollingTopWords, SkewedRollingTopWords, WordCountTopology

public abstract class ConfigurableTopology extends Object
Extensions of this class takes a reference to one or more configuration files. The main() method should call ConfigurableTopology.start() and it must instantiate a TopologyBuilder in the run() method.
 {
    public class MyTopology extends ConfigurableTopology {

   public static void main(String[] args) throws Exception {
       ConfigurableTopology.start(new MyTopology(), args);
   }

   @Override
   protected int run(String[] args) {
       TopologyBuilder builder = new TopologyBuilder();

       // build topology as usual

       return submit("crawl", conf, builder);
   }
 }