Re: Flux question

2015-10-02 Thread Nathan Leung
With regards to the first question, the purpose of flux is to dynamically create a topology for submission to nimbus. It serves to replace the topology main() method. It's is suitable for setting up configuration you use for connecting in prepare(), but it's not suitable for creating the connecti

Flux question

2015-10-02 Thread Ziemer, Tom
Hi, after using storm 0.9.4 for some time now, I finally had a look at 0.10.0-beta. One of the most interesting new features for me was FLUX. The documentation states that "...components are roughly analagous to Spring beans" and in the flux-examples (https://github.com/apache/storm/blob/master