Apache Storm 官方文档 —— 在生产环境中运行拓扑
在生产环境集群中运行拓扑的方式与本地模式非常相似，主要包括以下几个步骤： 1) 定义拓扑（如果使用 Java 进行开发就可以使用 TopologyBuilder） 2) 使用 StormSubmitter 向集群提交拓扑。StormSubmitter 接收拓扑...
Apache Storm 官方文档 —— 使用 Maven 构建 Storm 应用
在开发拓扑的时候，你需要在 classpath 中包含 Storm 的相关 jar 包。你可以将各个 jar 包直接包含到你的项目的 classpath 中，也可以使用 Maven 将 Storm 添加到依赖项中。Storm 已经集成到 Maven 的中心仓库中。你可以在项目的 pom.xml 中添...
Apache Storm 官方文档 —— 序列化
本文阐述了 Storm 0.6.0 以上版本的序列化机制。在低于 0.6.0 版本的 Storm 中使用了另一种序列化系统，详细信息可以参考 Serialization (prior to 0.6.0) 一文。 Storm 中的 tuple 可以包含任何类型的对象。由于 Stor...
Apache Storm 官方文档 —— 常用模式
本文列出了 Storm 拓扑中使用的一些常见模式，包括： 数据流的 join 批处理 BasicBolt 内存缓存与域分组的结合 Top N 流式计算 TimeCacheMap CoordinatedBolt 与 KeyedFairBolt Joins 数据流的 join 一般指的是通过共有的域来聚...
Apache Storm 官方文档 —— Storm 与 Kestrel
本文说明了如何使用 Storm 从 Kestrel 集群中消费数据。 前言 Storm 本教程中使用了 storm-kestrel 项目和 storm-starter 项目中的例子。建议读者将这几个项目 clone 到本地，并动手运行其中的例子。 Kestre...
Apache Storm 官方文档 —— 分布式 RPC
分布式 RPC（DRPC）的设计目标是充分利用 Storm 的计算能力实现高密度的并行实时计算。Storm 接收若干个函数参数作为输入流，然后通过 DRPC 输出这些函数调用的结果。严格来说，DRPC 并不能算作是 Storm 的一个特性，因为它只是一种基于 Storm 原语 (Stream、Spo...
Apache Storm 官方文档 —— Hooks
Storm 提供了一种 hooks 机制，可以实现在 Storm 的各种事件流中运行自定义代码的功能。可以通过继承 BaseTaskHook类来创建 hook，还可以根据需要在继承的子类中覆写适当的方法来跟踪相关事件。 注册 hook 有两种方法： 在 spout 的 open 方法或者 ...
Apache Storm 官方文档 —— Metrics
Storm 提供了一个可以获取整个拓扑中所有的统计信息的度量接口。Storm 内部通过该接口可以跟踪各类统计数字：executor 和 acker 的数量、每个 bolt 的平均处理时延、worker 使用的最大堆容量等等，这些信息都可以在 Nimbus 的 UI 界面中看到。 Metric 类型 ...
Apache Storm 官方文档 —— 使用非 JVM 语言开发
两个部分：创建拓扑，以及使用其他语言实现 spouts 与 bolts 由于 Storm 的拓扑都是基于 thrift 结构的，所以使用其他语言创建拓扑也是一件很容易的事情 使用其他语言实现的 spouts 与 bolts 称为“多语言组件”（multilang components）或者“脱壳”（...
Apache Storm 官方文档 —— 定义 Storm 的非 JVM 语言 DSL
实现非 JVM 语言 DSL（Domain Specific Language，领域专用语言）应该从 storm-core/src/storm.thrift 文件开始。由于 Storm 拓扑是 Thrift 结构，而且 Nimbus 是一个 Thrift 后台进程，你可以以任意语...
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
社区圈子
Apache您可能感兴趣
- Apache内存
- Apache geode
- Apache java
- Apache压力测试
- Apache测试
- Apache参数
- Apache工具
- Apache required
- Apache more
- Apache one
- Apache flink
- Apache配置
- Apache rocketmq
- Apache安装
- Apache php
- Apache dubbo
- Apache tomcat
- Apache服务器
- Apache linux
- Apache spark
- Apache开发
- Apache报错
- Apache服务
- Apache微服务
- Apache从入门到精通
- Apache doris
- Apache hudi
- Apache mysql
- Apache访问
- Apache日志