Hi All,
I have been looking the codes for ConfiguredBolt and its derivatives. I
realized that updateConfig is actually not doing much?

Would you describe how you manage configuration changes might be needed
after bolts are initialized and running?


for convenience, I copied the code here

public void updateConfig(String path, byte[] data) throws IOException {
  if (data.length != 0) {
    String name = path.substring(path.lastIndexOf("/") + 1);
    if (path.startsWith(ConfigurationType.ENRICHMENT.getZookeeperRoot())) {
      getConfigurations().updateSensorEnrichmentConfig(name, data);
      reloadCallback(name, ConfigurationType.ENRICHMENT);
    } else if (ConfigurationType.GLOBAL.getZookeeperRoot().equals(path)) {
      getConfigurations().updateGlobalConfig(data);
      reloadCallback(name, ConfigurationType.GLOBAL);
    }
  }



Thanks,

Reply via email to