善用风暴？

作者: 一号位
发布时间: 2024-04-18 01:32:40 (14小时前)
转自：

4 条回复

0#
回复此人
Jacob | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 如果您正在寻找快速，交互式可用且开发人员友好的批处理解决方案，您可能需要查看 <a href="http://spark.apache.org" rel="nofollow"> Apache Spark </A> 而不是风暴。 </p> <P> 当您想要在连续计算上运行查询时，Trident / DRPC更有用。 </p> </DIV>

编辑
1#
回复此人
文艺青年 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 当然可以使用Storm来处理有限的数据集合，并在处理完所有元素后停止。 DRPC拓扑是实现此目的的一种方法，但滚动自己的解决方案并不难。 </p> <P> 我们的想法是跟踪有限数据集中的哪些元素已被处理，这可以使用ack（）和fail（）方法在Spout中轻松完成。 </p> </DIV>

编辑
2#
回复此人
Autistic | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 找到了答案 <a href="https://groups.google.com/group/storm-user/browse_thread/thread/356735da5137aa1b#" rel="nofollow noreferrer"> 风暴谷歌组 </A> 。似乎DRCP拓扑将发出具有DRCP spout作为流接收的参数的元组，然后将在处理完成时指示回来（使用称为请求ID的唯一ID）。 </p> <P> 在同一个线程中说hadoop可能最适合这些情况，除非数据不够大并且可以完全处理。 </p> </DIV>

编辑

登录后才能参与评论