大約各位看官君多少也聽說了Storm/Spark/Flink，這些都是大數據流式處理框架。如果一條手機組裝流水線上不同的人做不同的事，有的裝電池，有的裝屏幕，直到最后完成，這就是典型的流式處理。如果手機組裝是先全部裝完電池，再交給裝屏幕的組，直到完成，這就是舊式的集合式處理。今天，就來先說 ...

前面說了Java8的流，這里還說流處理，既然是流，比如水流車流，肯定得有流的源頭，源可以有多種，可以自建，也可以從應用端獲取， 今天就拿非常經典的Kafka做源頭來說事，比如要來一套應用日志實時分析框架，或者是高並發實時流處理框架，正是Kafka的拿手好戲。 作者原創文章，謝絕一切轉載 ...

說到Stream便容易想到I/O Stream，而實際上，誰規定“流”就一定是“IO流”呢?在Java 8中，得益於Lambda所帶來的函數式編程，引入了一個全新的Stream概念，用於解決已有集合類庫既有的弊端。 引言 傳統集合的多步遍歷代碼 幾乎所有的集合(如 Collection 接口 ...

前言 最近在實習，在公司看到前輩的一些代碼，發現有很多值得我學習的地方，其中有一部分就是對集合使用Stream流式操作，覺得很優美且方便。所以學習一下Stream流，在這里記錄一下。 Stream是什么 Stream是Java 8中出現的新特性，極大增強了集合對象的功能，專注於對集合對象進行 ...

實時流式計算 - Kafka Stream 2.1 概述 Kafka Stream是Apache Kafka從0.10版本引入的一個新Feature。它是提供了對存儲於Kafka內的數據進行流式處理和分析的功能。 Kafka Stream的特點如下： Kafka Stream提供 ...

原創文章，謝絕任何形式轉載，否則追究法律責任！ ​流的世界，有點亂，群雄逐鹿，流實在太多，看完這個馬上又冒出一個，也不知哪個才是真正的牛，據說Flink是位重量級選手，能流計算，還能批處理， 和其他伙伴關系也融洽的很，與HDFS/File/SQL/MQ往來都不在話下，今天我們就來實戰一把 ...

什么是Stream？ Stream它並不是一個容器，它只是對容器的功能進行了增強，添加了很多便利的操作,例如查找、過濾、分組、排序等一系列的操作。並且有串行、並行兩種執行模式，並行模式充分的利用了多核處理器的優勢，使用fork/join框架進行了任務拆分，同時提高了執行速度。簡而言之 ...

個人原創文章，禁止任何形式轉載，否則追究法律責任！ 本文只發表在"公眾號"和"博客園"，其他均屬復制粘貼！如果覺得排版不清晰，請查看公眾號文章。 話說看圖看核心，代碼也得看核 ...