Package org.apache.storm.topology

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

Field Summary

Fields

Modifier and Type	Field	Description
protected Config	conf

Constructor Summary

Constructors

Constructor	Description
ConfigurableTopology()

Method Summary

Modifier and Type	Method	Description
protected Config	getConf()
static Config	loadConf(String resource, Config conf)
protected abstract int	run(String[] args)
static void	start(ConfigurableTopology topology, String[] args)
protected int	submit(String name, Config conf, TopologyBuilder builder)	Submits the topology under a specific name.
protected int	submit(Config conf, TopologyBuilder builder)	Submits the topology with the name taken from the configuration.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

conf

protected Config conf

Constructor Details

ConfigurableTopology

public ConfigurableTopology()

Method Details

start

public static void start(ConfigurableTopology topology,
 String[] args)

loadConf

public static Config loadConf(String resource,
 Config conf)
                       throws FileNotFoundException

Throws:

FileNotFoundException

getConf

protected Config getConf()

run

protected abstract int run(String[] args)
                    throws Exception

Throws:

Exception

submit

protected int submit(Config conf,
 TopologyBuilder builder)

Submits the topology with the name taken from the configuration.

submit

protected int submit(String name,
 Config conf,
 TopologyBuilder builder)

Submits the topology under a specific name.