#stream

      更多分类

Java Stream难题 - Heinz Kabutz

19-09-15 127 2 banq

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

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

19-08-27 42 banq

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

Java 8并行流的性能陷阱

19-08-15 55 banq

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

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

19-07-29 53 banq

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

流畅接口(Fluent Interface)

19-07-12 36 jdon

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

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

19-07-02 127 1 banq

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

集合管道模式(Collection Pipeline)

19-06-17 116 jdon

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

Java Optional使用的最佳实践

19-04-05 486 banq

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

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

19-03-27 280 banq

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

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

19-03-24 128 banq

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

Spring Cloud Stream对Kafka Streams的深度支持

19-03-13 544 banq

在编写流处理应用程序时,Spring Cloud Stream提供了另一个 专门用于Kafka Streams的绑定器 。与常规Kafka绑定器一样,Kafka Streams绑定器也专注于开发人员... 详细

Java流和状态

19-03-04 127 banq

使用Java 8流,似乎函数编程赢了,无状态和递归万岁!但是现实有点微妙:与软件编程一样, 它取决于 。我相信你的工具箱中的工具越多越好。 当你拥有的只是一把锤子时,一切看起来像钉子。 在... 详细

Proteus是使用RSocket构建流式微服务的新平台

19-02-07 148 banq

Netifi Proteus是类似Spring Cloud的,但是基于RSocket构建的下一代反应式微服务平台,它让开发人员通过在单个可部署中透明地提供API管理,路由,服务发现,预测负载平衡和超... 详细

reactor-kafka:使用Reactor的反应性Kafka实现程序

19-02-07 259 banq

这是使用Reactor的Kafka案例方式,生产者代码如下: /**  * Sample producer application using Reactive API for ... 详细

使用函数式方式实现责任链模式

19-01-29 57 banq

该模式包括创建一系列用于处理输入的对象。链中的每个对象都可以或不可以处理特定的输入,否则它会将输入传递给链的下一个对象。如果链中的最后一个对象也无法处理给定的输入,则链将无提示失败,或者更常见的是,... 详细

共有 441 2 3 下一页