Hi, I’ve been unable to find this in the Storm documentation:
How does the Storm topology loader identify if a Bolt is a “windowing” bolt and therefore needs to be wrapped with WindowedBoltExecutor? Does it look at: 1. Whether the Bolt’s getComponentConfiguration() method presents some or all of the windowing-related configuration parameters, as BaseWindowedBolt does; 2. Or does it use reflection to determine if the Bolt implements IWindowedBolt interface; 3. Or does the Bolt actually have to extend BaseWindowedBolt? There are indications in the docs that it is #2, but I wasn’t able to become certain. Please clarify. Thanks, --Matt
