I just came across your project. From the examples given it seems to showcase use of the library self contained with its own topology builder.
Can it support cases where one has their own external topology builder and management, and simply want to use this library to interface a node-based bolt/spout to the storm topology? e.g. a mixed stack storm topology (python, node, java/clojure, etc.).
I was able to do it with other node libraries like storm-node (https://www.npmjs.com/package/storm-node, https://github.com/STRML/storm-node, https://github.com/Lazyshot/storm-node), by simply requiring the module and then defining a bolt.
It's not clear from your example where one requires the module then defines a bolt function. I don't see a relation/link between the required module object and the bolt function until one uses the topology builder.
And also, how does one log a message to storm with this library? In other libraries it would be something like this.log(message) or self.log(message) within the bolt.
I just came across your project. From the examples given it seems to showcase use of the library self contained with its own topology builder.
Can it support cases where one has their own external topology builder and management, and simply want to use this library to interface a node-based bolt/spout to the storm topology? e.g. a mixed stack storm topology (python, node, java/clojure, etc.).
I was able to do it with other node libraries like storm-node (https://www.npmjs.com/package/storm-node, https://github.com/STRML/storm-node, https://github.com/Lazyshot/storm-node), by simply requiring the module and then defining a bolt.
It's not clear from your example where one requires the module then defines a bolt function. I don't see a relation/link between the required module object and the bolt function until one uses the topology builder.
And also, how does one log a message to storm with this library? In other libraries it would be something like
this.log(message)orself.log(message)within the bolt.