文件名称：trident-demo:三叉戟示威
文件大小：10KB
文件格式：ZIP
更新时间：2024-06-04 23:57:08
Java
三叉戟示威 介绍 该存储库包含单个三叉戟拓扑和在该拓扑上定义的DRPC流。 此拓扑用于演示两件事：仅处理一次语义和Trident的有状态处理。 我希望通过在本地创建的多节点群集中运行此拓扑来演示这些功能。 当拓扑运行时，我们将杀死所有工作节点，并通过查看redis服务器中存储的最终计数来得出结论，三叉戟只有一次语义和状态处理。 要遵循本教程，我假设您知道Storm和Trident是什么，并且对它们的核心抽象（即Spouts，Bolts，Stream等）有足够的了解。此外，我假设您知道什么是nimbus和supervisor 。 拓扑和DRPC流 拓扑简单地从输入喷嘴中读取单词流，并存储每个单词在redis服务器中的出现次数， redis服务器是键值缓存和存储。 在[1]中阅读有关redis更多信息。 输入喷口发出两批。 一批包含单词[ apple ， ball ， cat ， dog
【文件预览】：
trident-demo-master
----src()
--------main()
----pom.xml(3KB)
----README.md(8KB)