多语言接口协议 Storm 多语言协议 Shell 组件 输出域 协议报头 打包 协议 初始握手 Spouts Bolts 处理心跳（0.9.3 及以上版本适用） Spout Bolt 多语言接口协议 本文描述了 Storm （0.7.1 版本以上）的多语言接口协议。 Storm 多语言协议 Shell 组件 Sto...

Spark Streaming 基本操作 一、案例引入 2.2 updateStateByKey 2.3 启动测试 三、输出操作 3.1 输出API 3.1 foreachRDD 3.3 代码说明 3.4 启动测试 参考资料 Spark Streaming 基本操作 一、案例引入 这里先引入一个基本的案例来演示流的创建：获取指定...

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

Kafka client wrapper Apache Spark Apache Storm

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

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

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