零、序言 本篇文章探究Flink Window窗口機(jī)制，首先介紹窗口機(jī)制使用的總綱，涉及的所有組件進(jìn)行介紹，心中有一個(gè)大體的藍(lán)圖和認(rèn)識(shí)。之后基于keyBy方法返回的Keyed...
發(fā)簡(jiǎn)信
IP屬地：北京
-
Flink window窗口機(jī)制探究--以tumbling windows為例(一)
-
通過(guò)Flink 程序模板來(lái)學(xué)習(xí)StreamExecutionEnvironment 、DataStream 、StreamTransformation類
一、回到起點(diǎn) 一切都從最初的起點(diǎn)開始，我們來(lái)看官網(wǎng)給出的Flink Job程序的框架： 首先我們要?jiǎng)?chuàng)建StreamExecutionEnvironment，這是我們的流計(jì)算執(zhí)...
-
Flink 實(shí)時(shí)指標(biāo)計(jì)算之AggregateFunction計(jì)算事件發(fā)生次數(shù)和累計(jì)值
一、目標(biāo) 數(shù)據(jù)源為Kafka ，通過(guò)Flink 時(shí)間窗口AggregateFunction方法來(lái)進(jìn)行特定窗口內(nèi)消息事件的次數(shù)和累計(jì)值。 本例中：使用事件時(shí)間（Event Ti...
-
Redis基礎(chǔ)--基本數(shù)據(jù)類型
0 Redis 介紹 0.1 基礎(chǔ)知識(shí) 不僅僅是簡(jiǎn)單的key-value數(shù)據(jù)庫(kù)，更是一個(gè)in-memory data structure store。不僅僅支持簡(jiǎn)單的Stri...
-
Intellij ide+sbt+Flink+scala Windows開發(fā)環(huán)境配置(離線無(wú)網(wǎng)絡(luò))近期在無(wú)網(wǎng)絡(luò)環(huán)境內(nèi)網(wǎng) Window 環(huán)境配置 Flink開發(fā)環(huán)境，很艱苦。由于準(zhǔn)備使用Scala，根據(jù)官網(wǎng)Flink推薦使用sbt 來(lái)進(jìn)行配置管理，使用Intellij id...
-
微信公眾號(hào)python爬蟲之總體概況這兩天看公眾號(hào)回顧之前的文章，有些文章發(fā)現(xiàn)已經(jīng)被刪甚至有些公眾號(hào)直接被屏蔽了。甚是可惜，想著可以做一個(gè)微信公眾號(hào)的爬蟲來(lái)爬取文章保存到本地。 v0.1 功能 針對(duì)特定公眾號(hào)已...
-
Flink1.7.2 ZDH 集群 Standalone 模式獨(dú)立配置JDK1.8 小記
背景 實(shí)驗(yàn)室環(huán)境能夠申請(qǐng)的環(huán)境就是ZDH中興的R4B4集群，尚未能支持Flink組件。根據(jù)咨詢ZDH工程師，最新版本的應(yīng)該已經(jīng)有Flink組件了，但是仍然是實(shí)驗(yàn)性質(zhì)，并不會(huì)立...
-
寫給藝考生妹妹的高考動(dòng)員--關(guān)于文化課復(fù)習(xí)的一些見解（二）
接上文寫給藝考生妹妹的高考動(dòng)員--關(guān)于文化課復(fù)習(xí)的一些見解（一） 數(shù)學(xué)嘛， 數(shù)學(xué)本來(lái)就是美的化身和代表！ 一行行公式凝聚的是人類偉大的智慧結(jié)晶??！集合、函數(shù)、幾何、統(tǒng)計(jì)概率。...
-
寫給藝考生妹妹的高考動(dòng)員--關(guān)于文化課復(fù)習(xí)的一些見解（一）
前些日子跟藝考生妹妹的聊天，動(dòng)員吧，主要是談了談自己對(duì)高考各門課的見解，可能會(huì)有偏頗，可能沒(méi)有對(duì)癥下藥。也算高考動(dòng)員吧，第一篇主要包括：地理、歷史和政治。各位高考同學(xué)都有好的...
-
用 docker 來(lái)搭建獨(dú)立的 jupyter 環(huán)境
近期接觸docker ，感覺(jué)容器真是好東西，需要什么開發(fā)環(huán)境就搞一個(gè)對(duì)應(yīng)鏡像，docker運(yùn)行起來(lái)就可以用了，簡(jiǎn)單快捷，不讓自己的本子變成一個(gè)有各種開發(fā)環(huán)境的大雜燴。搭建獨(dú)立...