Class 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);

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

       // build topology as usual

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