3.1.0 版本 emqx-management (plugin) emqx-rule-engine (plugin) emqx-storm (plugin) 3.1.0 版本 发布日期: 2019-04-26 EMQ X 3.1.0 版本发布。此版本改动主要包括全面支持规则引擎、引入 storm 模块以支持 edge storm、 重构 f...

Getting started Installation via NPM Including the library Getting the javascript files Getting the CSS Render your first diagram Getting started Installation via NPM Th...

教程 序言 Storm 集群的组件 拓扑 流 数据模型 简单的拓扑示例 教程 在这篇教程中，你可以学到如何创建 Storm 的拓扑（topology），并将他们发布到 Storm 集群中。本文主要使用 Java，不过也会少量使用 Python 来说明 Storm 的多语言支持能力。 序言 本教程通过 storm-starter 项...

3.1.0 版本 emqx-management (plugin) emqx-rule-engine (plugin) emqx-storm (plugin) 3.1.0 版本 发布日期: 2019-04-26 EMQ X 3.1.0 版本发布。此版本改动主要包括全面支持规则引擎、引入 storm 模块以支持 edge storm、 重构 f...

Storm 内部技术实现 说明 Storm 内部技术实现 这部分的 wiki 是为了说明 Storm 是怎样实现的。在阅读本章之前你需要先了解怎样使用 Storm。 代码库架构 拓扑的生命周期1 消息传递的实现1 应答框架的实现 Metrics 事务型拓扑的工作机制1 单元测试2 时间模拟 完整的拓扑 集群跟踪 说明 1 该...

3.1.0 版本 emqx-management (plugin) emqx-rule-engine (plugin) emqx-storm (plugin) 3.1.0 版本 发布日期: 2019-04-26 EMQ X 3.1.0 版本发布。此版本改动主要包括全面支持规则引擎、引入 storm 模块以支持 edge storm、 重构 f...

BigData-Notes 前 言 一、Hadoop 二、Hive 三、Spark 四、Storm 五、Flink 六、HBase 七、Kafka 八、Zookeeper 九、Flume 十、Sqoop 十一、Azkaban 十二、Scala 十三、公共内容 后 记 BigData-Notes 大数据入门指南 ...

配置 配置 Storm 有大量配置项用于调整 nimbus、supervisors 和拓扑的行为。有些配置项是系统级的配置项，在拓扑中不能修改，另外一些配置项则是可以在拓扑中修改的。 每一个配置项都在 Storm 代码库的 defaults.yaml 中有一个默认值。可以通过在 Nimbus 和 Supervisors 的环境变量中定义一个 st...

消息的可靠性保障 消息的“完整性处理”是什么意思 在消息得到完整性处理后或者处理失败后会发生什么 Storm 的可靠性 API 在 tuple 可以被重新处理的前提下，如何让我的应用可以得到正确的运行？ Storm 是以怎样一种高效的方式实现可靠性的？ 调整可靠性 消息的可靠性保障 Storm 能够保证每一个由 Spout 发送的消息都能...

Transformation 和 Action 常用算子 一、Transformation 1.1 map 1.2 filter 1.3 flatMap 1.4 mapPartitions 1.5 mapPartitionsWithIndex 1.6 sample 1.7 union 1.8 intersection 1.9 distinct...