Pulsar adaptor for Apache Storm Using the Pulsar Storm Adaptor Pulsar Spout Pulsar Bolt Pulsar adaptor for Apache Storm Pulsar Storm is an adaptor for integrating with Apache...

内容 序列化 常用模式 使用非 JVM 语言开发 分布式 RPC Storm 与 Kestrel Hooks Metrics

Storm集成Kafka 一、整合说明 二、写入数据到Kafka 2.1 项目结构 2.2 项目主要依赖 2.3 DataSourceSpout 2.4 WritingToKafkaApp 2.5 测试准备工作 1. 启动Kakfa 2. 创建topic 3. 启动消费者 2.6 测试 三、从Kafka中读取数据 3.1 项目结构 3...

内容 基础概念 配置 消息的可靠性保障 容错性 命令行操作 理解 Storm 拓扑的并发数(parallelism)概念 FAQ

内容 定义 Storm 的非 JVM 语言 DSL 多语言接口协议（如何定义其他语言的接口） 技术实现相关文档

Storm 与 Kestrel 前言 Storm Kestrel Kestrel 服务器与队列 从 Kestrel 中移除数据 向 Kestrel 中连续添加数据 使用 KestrelSpout 运行 Storm 与 Kestrel 本文说明了如何使用 Storm 从 Kestrel 集群中消费数据。 前言 Storm 本教...

Storm 集成 Redis 详解 一、简介 二、集成案例 2.1 项目结构 2.2 项目依赖 2.3 DataSourceSpout 2.4 SplitBolt 2.5 CountBolt 2.6 WordCountStoreMapper 2.7 WordCountToRedisApp 2.8 启动测试 三、storm-redis 实现...

Storm 编程模型 一、简介 二、IComponent接口 三、Spout 3.1 ISpout接口 3.2 BaseRichSpout抽象类 四、Bolt 4.1 IBolt 接口 4.2 BaseRichBolt抽象类 五、词频统计案例 5.1 案例简介 5.2 代码实现 1. 项目依赖 2. DataSourceSpout 3....

Storm 核心概念详解 一、Storm核心概念 1.1 Topologies（拓扑） 1.2 Streams（流） 1.3 Spouts 1.4 Bolts 1.5 Stream groupings（分组策略） 二、Storm架构详解 2.1 Nimbus进程 2.2 Supervisor进程 2.3 zookeeper的作用 2.4...

创建 Storm 新项目 将 Storm 的 jar 包添加到 classpath 中 如果使用多语言接口，将多语言目录添加到 classpath 中 创建 Storm 新项目 本文简单介绍了新建 Storm 开发项目的方法，包括以下步骤： 将 Storm 的 jar 包添加到 classpath 中； 如果使用多语言接口，同样需要将多语言接...