前言 Flink 是一種流式計算框架，為什么我會接觸到 Flink 呢？因為我目前在負責的是監控平台的告警部分，負責采集到的監控數據會直接往 kafka 里塞，然后告警這邊需要從 kafka topic 里面實時讀取到監控數據，並將讀取到的監控數據做一些 聚合/轉換/計算 等操作 ...

Apache Flink是一個面向分布式數據流處理和批量數據處理的開源計算平台，它能夠基於同一個Flink運行時（Flink Runtime），提供支持流處理和批處理兩種類型應用的功能。現有的開源計算方案，會把流處理和批處理作為兩種不同的應用類型，因為他們它們所提供的SLA是完全不相同的：流 ...

什么是Flink Apache Flink是一個分布式大數據處理引擎，可以對有限數據流和無限數據流進行有狀態計算。可部署在各種集群環境，對各種大小的數據規模進行快速計算。 Flink特性 支持高吞吐、低延遲、高性能的流式數據處理，而不是用批處理模擬流式處理。 支持多種時間窗口 ...

在本文中，我們將從零開始，教您如何構建第一個Apache Flink （以下簡稱Flink）應用程序。 開發環境准備 Flink 可以運行在 Linux, Max OS X, 或者是 Windows 上。為了開發 Flink 應用程序，在本地機器上需要有 Java 8.x 和 maven 環境 ...

前言 目前有許多數據分析的場景從批處理到流處理的演變， 雖然可以將批處理作為流處理的特殊情況來處理，但是分析無窮集的流數據通常需要思維方式的轉變並且具有其自己的術語（例如，“win ...

前言 Data Sources 是什么呢？就字面意思其實就可以知道：數據來源。 Flink 做為一款流式計算框架，它可用來做批處理，即處理靜態的數據集、歷史的數據集；也可以用來做流處理，即實時的處理些實時數據流，實時的產生數據流結果，只要數據源源不斷的過來 ...

Flink 剖析 1.概述 　　在如今數據爆炸的時代，企業的數據量與日俱增，大數據產品層出不窮。今天給大家分享一款產品—— Apache Flink，目前，已是 Apache 頂級項目之一。那么，接下來，筆者為大家介紹Flink 的相關內容。 2.內容 2.1 What's ...

前言 再上一篇文章中 《Flink學習》—— Data Source 介紹 講解了 Flink Data Source ，那么這里就來講講 Flink Data Sink 吧。 首先 Sink 的意思是： 大概可以猜到了吧！Data ...