@Ignore @Test public void testMain0() throws Exception { String histFilePath = File.createTempFile("lrb-test", null).getAbsolutePath(); LRBTopologyMain.main0(0, 1, 2, "127.0.0.1", 5060, histFilePath, 2, false, true, 2, "nameext", 5000 ); }
public static void main0(int offset, int executors, int xways, String host, int port, String histFile, int tasks, boolean submit, boolean stormConfigDebug, int workers, String nameext, int runtimeMillis) throws AlreadyAliveException, InvalidTopologyException, FileNotFoundException { StopWatch stormTimer = new StopWatch(offset); String topologyNamePrefix = nameext + "_lrbNormal_" + "_L" + xways + "_" + workers + "W_T" + tasks + "_" + executors + "E_O" + offset; Config conf = new Config(); LRBTopology lRBTopology = new LRBTopology(nameext, xways, workers, tasks, executors, offset, new FileReaderSpout(), stormTimer, submit, histFile, topologyNamePrefix, conf); StormTopology topology = lRBTopology.getStormTopology(); conf.setDebug(stormConfigDebug); conf.put(AbstractOrderedFileInputSpout.INPUT_FILE_NAME, LRBTopologyMain.class.getResource("/datafile20seconds.dat").getFile()); Locale newLocale = new Locale("en", "US"); LOGGER.debug(String.format("setting locale to %s", newLocale)); Locale.setDefault(newLocale); LOGGER.debug("starting cluster: " + "stormlrb" + topologyNamePrefix); if(submit) { conf.setNumWorkers(workers); conf.setNumAckers(workers); StormSubmitter.submitTopology(topologyNamePrefix, conf, topology); } else { LocalCluster cluster = new LocalCluster(); cluster.submitTopology(TopologyControl.TOPOLOGY_NAME, conf, topology); Utils.sleep(runtimeMillis); cluster.killTopology(TopologyControl.TOPOLOGY_NAME); cluster.shutdown(); } }
LRBTopologyMain { public static void main0(int offset, int executors, int xways, String host, int port, String histFile, int tasks, boolean submit, boolean stormConfigDebug, int workers, String nameext, int runtimeMillis) throws AlreadyAliveException, InvalidTopologyException, FileNotFoundException { StopWatch stormTimer = new StopWatch(offset); String topologyNamePrefix = nameext + "_lrbNormal_" + "_L" + xways + "_" + workers + "W_T" + tasks + "_" + executors + "E_O" + offset; Config conf = new Config(); LRBTopology lRBTopology = new LRBTopology(nameext, xways, workers, tasks, executors, offset, new FileReaderSpout(), stormTimer, submit, histFile, topologyNamePrefix, conf); StormTopology topology = lRBTopology.getStormTopology(); conf.setDebug(stormConfigDebug); conf.put(AbstractOrderedFileInputSpout.INPUT_FILE_NAME, LRBTopologyMain.class.getResource("/datafile20seconds.dat").getFile()); Locale newLocale = new Locale("en", "US"); LOGGER.debug(String.format("setting locale to %s", newLocale)); Locale.setDefault(newLocale); LOGGER.debug("starting cluster: " + "stormlrb" + topologyNamePrefix); if(submit) { conf.setNumWorkers(workers); conf.setNumAckers(workers); StormSubmitter.submitTopology(topologyNamePrefix, conf, topology); } else { LocalCluster cluster = new LocalCluster(); cluster.submitTopology(TopologyControl.TOPOLOGY_NAME, conf, topology); Utils.sleep(runtimeMillis); cluster.killTopology(TopologyControl.TOPOLOGY_NAME); cluster.shutdown(); } } }
LRBTopologyMain { public static void main0(int offset, int executors, int xways, String host, int port, String histFile, int tasks, boolean submit, boolean stormConfigDebug, int workers, String nameext, int runtimeMillis) throws AlreadyAliveException, InvalidTopologyException, FileNotFoundException { StopWatch stormTimer = new StopWatch(offset); String topologyNamePrefix = nameext + "_lrbNormal_" + "_L" + xways + "_" + workers + "W_T" + tasks + "_" + executors + "E_O" + offset; Config conf = new Config(); LRBTopology lRBTopology = new LRBTopology(nameext, xways, workers, tasks, executors, offset, new FileReaderSpout(), stormTimer, submit, histFile, topologyNamePrefix, conf); StormTopology topology = lRBTopology.getStormTopology(); conf.setDebug(stormConfigDebug); conf.put(AbstractOrderedFileInputSpout.INPUT_FILE_NAME, LRBTopologyMain.class.getResource("/datafile20seconds.dat").getFile()); Locale newLocale = new Locale("en", "US"); LOGGER.debug(String.format("setting locale to %s", newLocale)); Locale.setDefault(newLocale); LOGGER.debug("starting cluster: " + "stormlrb" + topologyNamePrefix); if(submit) { conf.setNumWorkers(workers); conf.setNumAckers(workers); StormSubmitter.submitTopology(topologyNamePrefix, conf, topology); } else { LocalCluster cluster = new LocalCluster(); cluster.submitTopology(TopologyControl.TOPOLOGY_NAME, conf, topology); Utils.sleep(runtimeMillis); cluster.killTopology(TopologyControl.TOPOLOGY_NAME); cluster.shutdown(); } }  }
LRBTopologyMain { public static void main0(int offset, int executors, int xways, String host, int port, String histFile, int tasks, boolean submit, boolean stormConfigDebug, int workers, String nameext, int runtimeMillis) throws AlreadyAliveException, InvalidTopologyException, FileNotFoundException { StopWatch stormTimer = new StopWatch(offset); String topologyNamePrefix = nameext + "_lrbNormal_" + "_L" + xways + "_" + workers + "W_T" + tasks + "_" + executors + "E_O" + offset; Config conf = new Config(); LRBTopology lRBTopology = new LRBTopology(nameext, xways, workers, tasks, executors, offset, new FileReaderSpout(), stormTimer, submit, histFile, topologyNamePrefix, conf); StormTopology topology = lRBTopology.getStormTopology(); conf.setDebug(stormConfigDebug); conf.put(AbstractOrderedFileInputSpout.INPUT_FILE_NAME, LRBTopologyMain.class.getResource("/datafile20seconds.dat").getFile()); Locale newLocale = new Locale("en", "US"); LOGGER.debug(String.format("setting locale to %s", newLocale)); Locale.setDefault(newLocale); LOGGER.debug("starting cluster: " + "stormlrb" + topologyNamePrefix); if(submit) { conf.setNumWorkers(workers); conf.setNumAckers(workers); StormSubmitter.submitTopology(topologyNamePrefix, conf, topology); } else { LocalCluster cluster = new LocalCluster(); cluster.submitTopology(TopologyControl.TOPOLOGY_NAME, conf, topology); Utils.sleep(runtimeMillis); cluster.killTopology(TopologyControl.TOPOLOGY_NAME); cluster.shutdown(); } }  static void main(String[] args); static void main0(int offset, int executors, int xways, String host, int port, String histFile, int tasks, boolean submit, boolean stormConfigDebug, int workers, String nameext, int runtimeMillis); }
LRBTopologyMain { public static void main0(int offset, int executors, int xways, String host, int port, String histFile, int tasks, boolean submit, boolean stormConfigDebug, int workers, String nameext, int runtimeMillis) throws AlreadyAliveException, InvalidTopologyException, FileNotFoundException { StopWatch stormTimer = new StopWatch(offset); String topologyNamePrefix = nameext + "_lrbNormal_" + "_L" + xways + "_" + workers + "W_T" + tasks + "_" + executors + "E_O" + offset; Config conf = new Config(); LRBTopology lRBTopology = new LRBTopology(nameext, xways, workers, tasks, executors, offset, new FileReaderSpout(), stormTimer, submit, histFile, topologyNamePrefix, conf); StormTopology topology = lRBTopology.getStormTopology(); conf.setDebug(stormConfigDebug); conf.put(AbstractOrderedFileInputSpout.INPUT_FILE_NAME, LRBTopologyMain.class.getResource("/datafile20seconds.dat").getFile()); Locale newLocale = new Locale("en", "US"); LOGGER.debug(String.format("setting locale to %s", newLocale)); Locale.setDefault(newLocale); LOGGER.debug("starting cluster: " + "stormlrb" + topologyNamePrefix); if(submit) { conf.setNumWorkers(workers); conf.setNumAckers(workers); StormSubmitter.submitTopology(topologyNamePrefix, conf, topology); } else { LocalCluster cluster = new LocalCluster(); cluster.submitTopology(TopologyControl.TOPOLOGY_NAME, conf, topology); Utils.sleep(runtimeMillis); cluster.killTopology(TopologyControl.TOPOLOGY_NAME); cluster.shutdown(); } }  static void main(String[] args); static void main0(int offset, int executors, int xways, String host, int port, String histFile, int tasks, boolean submit, boolean stormConfigDebug, int workers, String nameext, int runtimeMillis);  }