搜索结果
查询Tags标签： Streams，共有 14条记录-
Kafka入门实战教程（7）：Kafka Streams
1 关于流处理 流处理平台（Streaming Systems）是处理无限数据集（Unbounded Dataset）的数据处理引擎，而流处理是与批处理（Batch Processing）相对应的。所谓的无线数据，指的是数据永远没有尽头。而流处理平台就是专门处理这种数据集的系统或框架。下图生动形象地展示…
2022/7/21 6:24:38 人评论 次浏览 -
RocketMQ-Streams架构设计浅析
*作者：倪泽，RocketMQ 资深贡献者， RocketMQ-Streams 维护者之一，阿里云技术专家。 * RocketMQ-Streams 是一款轻量级流处理引擎，应用以SDK 的形式嵌入并启动，即可进行流处理计算，不依赖于其他组件，最低1核1G可部署，在资源敏感场景具有很大优势。同时它支持 UTF/U…
2022/4/6 23:19:59 人评论 次浏览 -
RFC9000中文文档 第二章：Streams
2.Stream QUIC 中的流为应用程序提供了轻量级、有序的字节流抽象。 流可以是单向的或双向的。 可以通过发送数据来创建流。 与流管理相关的其他过程——结束、取消和管理流控制——都旨在施加最小的开销。 例如，单个 STREAM 帧（第 19.8 节）可以打开、携带和关闭流的数据…
2022/2/19 6:14:30 人评论 次浏览 -
Redis Streams 学习资料整理
前言 Redis Stream 是 Redis 5.0 版本新增加的数据结构。 Redis Stream 主要用于消息队列（MQ，Message Queue），Redis 本身是有一个 Redis 发布订阅 (pub/sub) 来实现消息队列的功能，但它有个缺点就是消息无法持久化，如果出现网络断开、Redis 宕机等，消息就会被丢弃。…
2022/1/19 19:21:27 人评论 次浏览 -
Redis Streams 学习资料整理
前言 Redis Stream 是 Redis 5.0 版本新增加的数据结构。 Redis Stream 主要用于消息队列（MQ，Message Queue），Redis 本身是有一个 Redis 发布订阅 (pub/sub) 来实现消息队列的功能，但它有个缺点就是消息无法持久化，如果出现网络断开、Redis 宕机等，消息就会被丢弃。…
2022/1/19 19:21:27 人评论 次浏览 -
【物联网】9.物联网数据分析方法 - 流处理（Spark，Storm）
批处理是把数据攒起来，一次性进行处理的方法。相对而言，流处理是不保存数据，按照到达处理服务器的顺序对数据依次进行处理。 想实时对数据做出反应时，流处理是一个很有效的处理方法。因为批处理是把数据积攒之后隔一段时间进行处理，所以从数据到达之后到处理完毕为止…
2021/10/10 23:48:09 人评论 次浏览 -
【物联网】9.物联网数据分析方法 - 流处理（Spark，Storm）
批处理是把数据攒起来，一次性进行处理的方法。相对而言，流处理是不保存数据，按照到达处理服务器的顺序对数据依次进行处理。 想实时对数据做出反应时，流处理是一个很有效的处理方法。因为批处理是把数据积攒之后隔一段时间进行处理，所以从数据到达之后到处理完毕为止…
2021/10/10 23:48:09 人评论 次浏览 -
Java Streams 中的异常处理
这里写目录标题 处理异常代码块运行时异常Either处理Stream异常结束语处理异常代码块 Stream API 和 lambda 是自第 8 版以来 Java 中的重大改进。从那时起，我们可以使用更具功能性的语法样式。现在，在使用这些代码结构几年后，仍然存在的较大问题之一是如何处理 lambda…
2021/7/31 11:07:08 人评论 次浏览 -
Java Streams 中的异常处理
这里写目录标题 处理异常代码块运行时异常Either处理Stream异常结束语处理异常代码块 Stream API 和 lambda 是自第 8 版以来 Java 中的重大改进。从那时起，我们可以使用更具功能性的语法样式。现在，在使用这些代码结构几年后，仍然存在的较大问题之一是如何处理 lambda…
2021/7/31 11:07:08 人评论 次浏览 -
Oracle数据泵expdp遭遇Streams AQ: Enqueue Blocked On Low Memory等待事件
Oracle数据泵expdp遭遇Streams AQ: Enqueue Blocked On Low Memory等待事件版本：11.2.0.4.0 PSU+OJVM：11.2.0.4.201020 对数据库使用expdp做全库导出时，发现异常的慢。 每张小表的导出都要隔个几秒才会继续导出下一张表。 查看数据泵会话的等待事件信息如下：10:00:51 …
2021/6/30 19:23:49 人评论 次浏览 -
Oracle Linux 8.0发布
Oracle Linux 8.0 发布了，更新包中包括基础 BaseOS 和 Application Streams，其中 BaseOS 提供运行环境的用户空间，Application Streams 提供了一系列以往分发在软件集中的应用，以及可在用户空间内运行的其它产品和程序。此版本主要亮点包括： Application Streams Ora…
2021/5/22 2:25:44 人评论 次浏览 -
一、响应式编程的产生_Reactive Streams组件使用、源码理解
1.响应式编程的产生背景：为了解决异步编程过程中出现的种种难题，人们提出了各种各样方法来规避这些问题，这些方法称为响应式编程(Reactive Programming)，就像面向对象编程、函数式编程一样，响应式编程也是另一种编程范式。响应式编程，本质上是对数据流或某种变化所作…
2021/5/13 22:27:05 人评论 次浏览 -
深入浅出了解Node.js Streams
这篇文章讲了了解流的用途，为什么它们如此重要，以及如何使用它们。下面我们来一起学习吧
2019/6/29 22:53:22 人评论 次浏览 -
Node.js Streams文件读写操作详解
如果你在处理应用中 I/O 相关的操作，你可以利用 Node.js 中的流(stream)，这篇文章主要为大家详细介绍了Node.js Streams文件读写操作，感兴趣的小伙伴们可以参考一下
2019/6/27 22:17:16 人评论 次浏览
