序列化 动态类型 定制序列化 Java 序列化 特定组件的序列化注册 序列化 本文阐述了 Storm 0.6.0 以上版本的序列化机制。在低于 0.6.0 版本的 Storm 中使用了另一种序列化系统，详细信息可以参考 Serialization (prior to 0.6.0) 一文。 Storm 中的 tuple 可以包含任何类型的对...

配置开发环境 什么是开发环境？ 在本地机器上安装 Storm 在远程集群上开始/终止拓扑的运行 配置开发环境 本文详细讲解了配置 Storm 开发环境的相关信息。简单地说，配置过程包含以下几个步骤： 下载 Storm 发行版 ，将其解压缩并复制到你的 PATH 环境变量的 bin 目录中（也可以根据需要自定义安装目录 —— 译者注）； ...

问题与解决 Worker 进程在启动时挂掉而没有留下堆栈跟踪信息的问题 节点之间无法通信 拓扑在一段时间后停止了 tuple 的处理过程 Storm UI 中没有显示出所有的 supervisor 信息 “Multiple defaults.yaml found” 错误 运行 storm jar 命令时出现 “NoSuchMethorError” ...

Map & Tuple 一、映射(Map) 1.1 构造Map 1.2 获取值 1.3 新增/修改/删除值 1.4 遍历Map 1.5 yield关键字 1.6 其他Map结构 1.7 可选方法 1.8 与Java互操作 二、元组(Tuple) 2.1 模式匹配 2.2 zip方法 参考资料 Map & Tuple 一...

源码组织结构 storm.thrift Java 接口 实现 Java packages Clojure namespaces 源码组织结构 Strom 的代码有三个层次： 第一，Storm 在一开始就是按照兼容多语言的目的来设计的。Nimbus 是一个 Thrift 服务，拓扑也被定义为 Thrift 架构。Thrift 的使用使得 S...

命令行操作 jar kill activate deactivate rebalance repl classpath localconfvalue remoteconfvalue nimbus supervisor ui drpc 命令行操作 本文介绍了 Storm 命令行客户端中的所有命令操作。如果想要了解怎样设置你的 ...

在生产环境中运行拓扑 常用配置 Kill 拓扑 更新运行中的拓扑 监控拓扑 在生产环境中运行拓扑 在生产环境集群中运行拓扑的方式与本地模式 非常相似，主要包括以下几个步骤： 1) 定义拓扑（如果使用 Java 进行开发就可以使用 TopologyBuilder ） 2) 使用 StormSubmitter 向集群提交拓扑。StormSu...

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...

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...

About Storm 官方文档索引 Storm 基础篇 Trident 配置与部署 Storm 中级篇 Storm 高级篇 说明 来源(书栈小编注) About 本项目是 Apache Storm 官方文档的中文翻译版，致力于为有实时流计算项目需求和对 Apache Storm 感兴趣的同学提供有价值的中文资料，希望能够对大家的工作...