《Storm分布式实时计算模式》——3.4 Trident运算
本节书摘来自华章计算机《Storm分布式实时计算模式》一书中的第3章,第3.4节,作者:(美)P. Taylor Goetz Brian O’Neill 更多章节内容可以访问云栖社区“华章计算机”公众号查看。 3.4 Trident运算 时间戳已经生成好了,下一步是加入处理事件的逻辑组件。在Trident中,这些组件称为运算(operation)。在我们的topology中,使用两种不同的运算:filter和function。运算通过Stream对象的方法来调用。这个例子中,我们使用了Stream对象的下述方法: https://yqfile.alicdn.com/46e7bea64528ebdb3f64b3cb53140489e03591ff.png " > 注意前面代码中列出的方法返回形式为Stream对象或者TridentSta