什么是Stream 首先要說的是，不要被它的名稱騙了，這里的Stream跟JAVA I/O中的InputStream和OutputStream是兩個不同的概念。Java 8中的Stream其實是函數 ...

data stream的背后可以認為是一組自動創建的index。 數據流允許跨多個index僅追加時間序列數據，同時為請求提供單個index的命名（別名）。數據流非常適合於日志、事件、度量和其 ...

　　隨着數據時代的到來，數據的實時計算也越來越被大家重視。實時計算的一個重要方向就是實時流計算，目前關於流計算的有很多成熟的技術實現方案，比如Storm、Spark Streaming、flink等。我今天要講的kafka streams體量上來說沒有那么大，都算不上一個框架，只是kafka的一個 ...

1. 背景 上一篇介紹了如何利用Kafka Streams實時統計某年最賣座和最不賣座的電影票房。主要的方法是通過Streams提供的aggregate方法實現了max/min算子。今天我為大家帶來時間窗口函數的使用方法。在Kafka Streams中，時間窗口有三類：固定時間窗口 ...

首先看一個問題：在這個task集合中一共有多少個OPEN狀態的？計算出它們的points屬性和。在Java 8之前，要解決這個問題，則需要使用foreach循環遍歷task集合；但是在Java 8中可 ...

背景 上一篇我們介紹了Kafka Streams中的消息轉換操作map，今天我們給出另一個經典的轉換操作filter的用法。依然是結合一個具體的實例展開介紹。 演示功能說明 本篇演示filter用法，即根據給定的過濾條件或邏輯實時對每條消息進行過濾處理。今天使用的輸入topic消息格式 ...

1.概述 　　Kafka Streams 是一個用來處理流式數據的庫，屬於Java類庫，它並不是一個流處理框架，和Storm，Spark Streaming這類流處理框架是明顯不一樣的。那這樣一個庫是做什么的，能應用到哪些場合，如何使用。筆者今天就給大家來一一剖析這些內容。 2.內容 ...

流式編程作為Java 8的亮點之一，是繼Java 5之后對集合的再一次升級，可以說Java 8幾大特性中，Streams API 是作為Java 函數式的主角來設計的,誇張的說，有了Streams API之后，萬物皆可一行代碼。 什么是Stream Stream被翻譯為流，它的工作過程像將一瓶 ...