#stream流处理

Kafka真正定位并不是消息系统

17-09-18 7765 19 banq

本文是Kafka创始人的一篇博客,认为Kafka可以用于像数据库那样持久存储,这与人们通常对消息系统的印象不同,其实Kafka真正定位是一个日志系统,消息队列只是其一个应用模式,如同会气功的人玩劈砖一... 详细

Java Stream API groupingBy()介绍

18-09-21 9682 9 banq

groupingBy()是Stream API中最强大的收集器Collector之一,提供与SQL的GROUP BY子句类似的功能。 使用形式如下: .collect(groupingB... 详细

使用Spring Boot和Kafka Streams实现CQRS

18-10-21 4690 2 banq

本文是David Romero一篇Spring + Kafka Stream实现CQRS的案例代码: 去年九月,我的同事伊万·古铁雷斯和我谈到我们cowokers如何实现事件与Kafka Stre... 详细

Reactive流介绍

16-11-30 3026 3 banq

现代系统中的数据是不断变化的,而不是静止的,现代软件越来越多地基于近实时的数据运行。 大数据不如快速数据重要,快速数据对快速knowledge特别重要。流处理是帮助将所有大小的数据尽快转换为know... 详细

服务与数据之争

18-08-22 1 608 1 banq

SOA是面向服务的架构,大数据是处理大规模数据,这两个门派其实还是有很大区别的。 服务是一种对象化概念,一个服务包含很多函数方法,基于服务的治理从服务注册发现 集成 路由和流程; 数据处理从函数式编... 详细

Trampolining:java开发人员的实用指南

16-11-17 544 banq

Trampolining是每个java程序员应该知道的概念,它代表计算的两个状态之一,一个代表计算完成有结果,另外一个指向计算下一步reminder,有点类似java.util.Supplier 所做... 详细

用Java实现Stream流处理中的滑窗

18-09-04 470 banq

简单地说,滑窗算法是一种移动固定大小的窗口(子列表)来遍历数据结构的方法,主要是基于固定步骤的序列流数据。 如果我们想通过使用大小为3的窗口遍历列表[1 2 3 4 5],我们透过窗口只能看到以下数... 详细

Java 10中Stream API不可变集合

18-09-24 381 banq

不可变数据结构能够应对高并发,无锁并发,JDK10提供Stream API不可变集合。 默认情况下,大多数Stream API集合代表可变的集合策略 - 但是如果想要将元素收集到不可变数据结构会发生... 详细

共有 64 上一页 1 ... 4 5 6 7 8 下一页