2014-12-07 91 views
0

Storm支持多种流,但我无法在Redstorm中找到相关dsl,任何知道它是否受支持,以及如何使用它?Redstorm是否支持多个流

感谢您的任何帮助。

回答

0

DSL目前不提供指定不同流的机制,但您可以使用TopologyBuilder类来完成。

java_import 'backtype.storm.topology.TopologyBuilder' 

topology_builder = TopologyBuilder.new(...) 
... 
topology_builder.setBolt(...).shuffleGrouping('source', 'stream')