#stream

      更多分类

事件溯源:投影或投射模式 -Kacper Gunia

19-11-13 238 1 banq

投影是事件源中使用的核心模式之一。ES所了解的是,作为一系列事件将应用程序中正在发生的更改持久化。然后,该事件序列(也称为流)可用于重建当前状态,以便可以处理任何后续请求。 从理论上讲,我们可以仅在... 详细

Spring WebFlux的明显陷阱 - ŁukaszKyć

19-11-08 504 1 banq

几个月前,我们开始了一个新项目。我们的目标是设计一个可以处理许多并发连接的微服务。我们预测该应用程序将花费大量时间等待多个并行I / O操作。理想的体系结构解决方案似乎使用了非阻塞方法。经过简短的调... 详细

Spring Cloud Stream事件路由 - spring.io

19-11-07 370 banq

Spring Cloud Stream(SCSt)的事件路由有以下功能:a)将事件路由到特定事件订阅者,或b)将事件订阅者产生的事件路由到特定目的地。 让我们快速看一下基于注释的编程模型中的工作方式... 详细

Spring Cloud Stream的函数式和响应式Reactive编程特点 - spring.io

19-10-26 198 banq

Spring Cloud Stream(SCSt)的函数式和反应式Reactive编程带来更少的代码、更少的配置。不过,最重要的是,您的代码是完全分离的,并且与SCSt的内部结构无关。 虽然下面描述... 详细

Kafka教程大全指引 - DZone Big Data

19-10-23 89 banq

卡夫卡基础知识 在   《 Kafka简介》中 ,开发人员Prashant Sharma讨论了Kafka的基础知识,包括消息传递系统背后的基础知识,Kafka的好处以及平台中的关键主题(主题,... 详细

Java Stream难题 - Heinz Kabutz

19-09-15 372 2 banq

下面输出是多少?   IntStream.range(0, 5)         .parallel()         .sorted()         .forEach(Syste... 详细

Kafka基础:表和流的区别 - Edward Loveall

19-08-27 86 banq

使用 Kafka Streams 消费主题时, 您需要使用两种数据。一个是流stream,一个是表table。 我们来看一些数据: 下面是User数据 . 详细

Java 8并行流的性能陷阱

19-08-15 87 banq

并行化流被分成多个块,每个块独立处理,结果在最后汇总。 CPU密集型代码如下: private long countPrimes( int max) {     retur... 详细

Kafka如何实现实时流处理 Part 1 - André Melo

19-07-29 72 banq

Apache Kafka可能主要被称为消息传递中间件,其结构比队列更灵活,但它也使团队能够更低地进入实时数据管道。 使用Kafka的所谓流应用程序具有可扩展性,容错性,并且显示强大的排序和交付保证,... 详细

流畅接口(Fluent Interface)

19-07-12 54 jdon

目的 Fluent Interface提供易于阅读,流畅的接口,通常模仿领域特定的语言。使用此模式会产生几乎可以像人类语言一样阅读的代码。 执行 可以使用任何一个实现Fluent In... 详细

使用Spring Boot RESTful Web服务实现流式数据 | Techshard

19-07-02 256 1 banq

流数据是向Web浏览器发送数据的一种全新方法,可显着加快页面加载速度。通常,我们需要允许用户在Web应用程序中下载文件。当数据太大时,提供良好的用户体验变得非常困难,使用StreamingRespo... 详细

集合管道模式(Collection Pipeline)

19-06-17 128 jdon

目的 Collection Pipeline引入了函数组合和集合管道,这两种函数式模式可以组合在一起来迭代代码中的集合。在函数式编程中,通过一系列较小的模块化函数或操作来对复杂操作进行排序是很... 详细

Java Optional使用的最佳实践

19-04-05 1278 banq

这是 piotr szybicki 4年来为了解正确使用Optional类型而努力的结果。 Optional隐藏了可能存在空指针的不确定性,比如: . 详细

使用Java Stream API中DistinctBy删除重复数据

19-03-27 424 banq

Stream API提供distinct()方法,该方法基于数据Object类的equals()方法返回列表的不同元素。下面先做一个数据Object类,用来发现重复数据: public... 详细

从数据库读取许多实体,JAVA 8流或反应流哪个有更好的性能?

19-03-24 156 banq

吞吐量性能取决于底层实现。在返回Stream之前将所有行收集到List的查询可能比从ResultSet中按元素读取要慢。 Reactive目前会有更多开销,因此较小的结果会产生更高的总查询持续时间。... 详细

共有 491 2 3 4 下一页