apache-storm - 使用 Trident 拓扑有什么好处?它与 DRPC 拓扑有何不同?

标签 apache-storm

我是Storm新手..请帮我看清楚Trident拓扑。我也想知道Trident拓扑有什么样的需求套件?

最佳答案

Trident 基本上是一个建立在 Storm 之上的抽象,它允许有状态的流处理。与消息的 Storm “至少一次处理”相反,它确保消息的“恰好一次处理”。
来自 tutorial

Trident is a high-level abstraction for doing realtime computing on top of Storm. It allows you to seamlessly intermix high throughput (millions of messages per second), stateful stream processing with low latency distributed querying. If you're familiar with high level batch processing tools like Pig or Cascading, the concepts of Trident will be very familiar – Trident has joins, aggregations, grouping, functions, and filters. In addition to these, Trident adds primitives for doing stateful, incremental processing on top of any database or persistence store. Trident has consistent, exactly-once semantics, so it is easy to reason about Trident topologies.



对于用例,您可以通过 this SO中的讨论
查看 API 概览 here

我可以找到更多有用的链接
http://www.datasalt.com/2013/04/an-storms-trident-api-overview/
http://asakta.blogspot.in/2013/04/learning-to-hold-trident-in-storm.html

关于apache-storm - 使用 Trident 拓扑有什么好处?它与 DRPC 拓扑有何不同?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19651478/

相关文章:

apache-storm - 使用 accumulo 运行 Storm 连接时出错

apache-storm - Apache Storm 中 Fields 类的用途是什么

hadoop - HDFS的并行提示

java - Storm 与卡夫卡 : Increasing amount of open file descriptors

java - Intellij IDEA Maven : can't resolve symbol "backtype"

java - Apache Storm 尝试本地主机 Zookeeper 连接,而不是指定的 Zookeeper 服务器列表

ubuntu - apache Storm yaml blockmappingstart 消息

exception - Storm dprc thrift7.transport.TTransportException : Frame size (1213486160) larger than max length (1048576)!

apache-storm - Flink 和 Storm 之间的主要区别是什么?

java - Cassandra 计数器查询期间的字符串验证错误