Metrics Metric 类型 Metric Consumer 构建自定义 metric 内建的 Metric Metrics Storm 提供了一个可以获取整个拓扑中所有的统计信息的度量接口。Storm 内部通过该接口可以跟踪各类统计数字：executor 和 acker 的数量、每个 bolt 的平均处理时延、worker 使用的最大...

使用非 JVM 语言开发 以非 JVM 语言实现 DSL 的相关说明 使用非 JVM 语言开发 两个部分：创建拓扑，以及使用其他语言实现 spouts 与 bolts 由于 Storm 的拓扑都是基于 thrift 结构的，所以使用其他语言创建拓扑也是一件很容易的事情 使用其他语言实现的 spouts 与 bolts 称为“多语言组件”（mult...

Kafka client wrapper Apache Spark Apache Storm

Kafka client wrapper Apache Spark Apache Storm

事件处理(CEP) Storm兼容适配 图计算: Gelly 机器学习

[TOC] Powered by Calcite The following companies and projects are powered by Apache Calcite. Is your company or project powered by Calcite? Add it to this page and then u...

Trident Spouts 管道 Trident spout 类型 Trident Spouts 与一般的 Storm API 一样，spout 也是 Trident 拓扑的数据来源。不过，为了实现更复杂的功能服务，Trident Spout 在普通的 Storm Spout 之上另外提供了一些 API 接口。 数据源、数据流以及基于数据流更...

FAQ Storm 最佳实践 关于配置 Storm + Trident 的建议 如何避免 worker 总是出现莫名其妙的故障的问题 Help！Storm 使用过程中无法获取： 我应该使用多少个 worker？ 拓扑 Trident 拓扑支持多数据流吗 Spout Coordinator 是什么，为什么会有很多 Coordinator？ 在 ...

Kafka client wrapper Apache Spark Apache Storm

Kafka client wrapper Apache Spark Apache Storm