package demo.storm;

import java.util.ArrayList;
import java.util.List;

import org.apache.storm.Config;
import org.apache.storm.StormSubmitter;
import org.apache.storm.topology.TopologyBuilder;

public class WordStormProd {
	public static void main(String[] args) throws Exception {
		Config config = new Config();
		config.put("inputFile", args[0]);
		//config.setDebug(true);
		//config.setMaxSpoutPending(1);
		List<String> nimbus_hosts = new ArrayList<String>();
		nimbus_hosts.add("sandbox.hortonworks.com");
		//config.put(Config.NIMBUS_SEEDS, nimbus_hosts);

		TopologyBuilder builder = new TopologyBuilder();
		builder.setSpout("line-reader-spout", new LineReaderSpout());
		builder.setBolt("word-splitter", new WordSplitterBolt()).shuffleGrouping("line-reader-spout");
		builder.setBolt("word-counter", new WordCounterBolt()).shuffleGrouping("word-splitter");

		StormSubmitter.submitTopology("mytopology", config, builder.createTopology());
	}
}