Storm入门之第三章拓扑
本文翻译自《Getting Started With Storm》译者:吴京润 编辑:方腾飞 在这一章,你将学到如何在同一个Storm拓扑结构内的不同组件之间传递元组,以及如何向一个运行中的Storm集群发布一个拓扑。 数据流组 设计一个拓扑时,你要做的最重要的事情之一就是定义如何在各组件之间交换数据(数据流是如何被bolts消费的)。一个数据流组指定了每个bolt会消费哪些数据流,以及如何消费它们。 NOTE:一个节点能够发布一个以上的数据流,一个数据流组允许我们选择接收哪个。 数据流组在定义拓扑时设置,就像我们在第二章看到的: ··· builder.setBolt("word-normalizer", new WordNormalizer()) .shuffleGrouping("word-reader"); ··· 在前面的代码块里,一个bolt由TopologyBuilder对象设定, 然后使用随机数据流组指定数据源。数据流组通常将数据源组件的ID作为参数,取决于数据流组的类型不同还有其它可选参数。 NOTE:每个InputDeclarer可以有一个以上的数据源,而且每个数据...