一：流處理的基本概念 　　流處理系統本身有很多自己的特點。一般來說，由於需要支持無限數據集的處理，流處理系統一般采用一種數據驅動的處理方式。它會提前設置一些算子，然后等到數據到達后對數據進行處理。 　　為了表達復雜的邏輯，flink在內的分布式流處理引擎，一般采用 DAG 圖來表示整個計算邏輯 ...

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

，Flink 就能夠一直計算下去，這個 Data Sources 就是數據的來源地。 Flink 中 ...

正文前先來一波福利推薦： 福利一： 百萬年薪架構師視頻，該視頻可以學到很多東西，是本人花錢買的VIP課程，學習消化了一年，為了支持一下女朋友公眾號也方便大家學習，共享給大家。 福利二： 畢業 ...

一、flink在批處理中常見的source 　　flink在批處理中常見的source主要有兩大類: 　 　　　　1.基於本地集合的source（Collection-based-source） 　　 　　　　2.基於文件的source（File-based-source ...

公司主要做的事物聯網和數字孿生，下半年我們項目要接入大數據，要進行處理再整合Drools，進行規則預警。最近幾個月一直在忙pmp考試和平時工作，也沒有進行學習整理，最近就開始學習flink和kafka，記點筆記。 Flink組件棧 一個計算框架要有長遠的發展，必須打造一個完整的 Stack ...

轉自：https://blog.csdn.net/axiaoboge/article/details/84335452 Java提供了種類豐富的鎖，每種鎖因其特性的不同，在適當的場景下能夠展現出非常高的效率。本文旨在對鎖相關源碼（本文中的源碼來自JDK 8）、使用場景進行舉例，為讀者介紹主流 ...

一、dict的特性 　　dict是python中的一個可變的數據類型，用{}表示，dict的key必須是不可變的數據類型，而value的數據類型可以任意 　　格式：{key:value,key:value,key:value} 　　注：鍵值對如果是字符串使用單引號，最后一個鍵值對沒有逗號 ...