(Nimbus.Iface client, String topology)
| 34 | private String watch; |
| 35 | |
| 36 | private HashSet<String> getComponents(Nimbus.Iface client, String topology) throws Exception { |
| 37 | HashSet<String> components = new HashSet<>(); |
| 38 | GetInfoOptions getInfoOpts = new GetInfoOptions(); |
| 39 | getInfoOpts.set_num_err_choice(NumErrorsChoice.NONE); |
| 40 | TopologyInfo info = client.getTopologyInfoByNameWithOpts(topology, getInfoOpts); |
| 41 | for (ExecutorSummary es : info.get_executors()) { |
| 42 | components.add(es.get_component_id()); |
| 43 | } |
| 44 | return components; |
| 45 | } |
| 46 | |
| 47 | public void metrics(Nimbus.Iface client) throws Exception { |
| 48 | if (interval <= 0) { |
no test coverage detected