@Test public void testNumWorkers() { assertEquals(Integer.parseInt(propertyParser.getProperty(ConfigVars.STORM_NUM_WORKERS_KEY)), (int) stormLocalCluster.getNumWorkers()); }
public Integer getNumWorkers() { return numWorkers; }
StormLocalCluster implements MiniCluster { public Integer getNumWorkers() { return numWorkers; } }
StormLocalCluster implements MiniCluster { public Integer getNumWorkers() { return numWorkers; } private  StormLocalCluster(Builder builder); }
StormLocalCluster implements MiniCluster { public Integer getNumWorkers() { return numWorkers; } private  StormLocalCluster(Builder builder); String getZookeeperHost(); Long getZookeeperPort(); Boolean getEnableDebug(); Integer getNumWorkers(); Config getStormConf(); @Override void start(); @Override void stop(); @Override void stop(boolean cleanUp); @Override void configure(); @Override void cleanUp(); void submitTopology(String topologyName, Config conf, StormTopology topology); void stop(String topologyName); }
StormLocalCluster implements MiniCluster { public Integer getNumWorkers() { return numWorkers; } private  StormLocalCluster(Builder builder); String getZookeeperHost(); Long getZookeeperPort(); Boolean getEnableDebug(); Integer getNumWorkers(); Config getStormConf(); @Override void start(); @Override void stop(); @Override void stop(boolean cleanUp); @Override void configure(); @Override void cleanUp(); void submitTopology(String topologyName, Config conf, StormTopology topology); void stop(String topologyName);  }