發(fā)簡(jiǎn)信
IP屬地：北京
-
Flink window窗口機(jī)制探究--以tumbling windows為例(一)
零、序言 本篇文章探究Flink Window窗口機(jī)制，首先介紹窗口機(jī)制使用的總綱，涉及的所有組件進(jìn)行介紹，心中有一個(gè)大體的藍(lán)圖和認(rèn)識(shí)。之后基于...
-
通過(guò)Flink 程序模板來(lái)學(xué)習(xí)StreamExecutionEnvironment 、DataStream 、StreamTransformation類(lèi)
一、回到起點(diǎn) 一切都從最初的起點(diǎn)開(kāi)始，我們來(lái)看官網(wǎng)給出的Flink Job程序的框架： 首先我們要?jiǎng)?chuàng)建StreamExecutionEnviro...
-
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ì)值。 本例中：...
-
Redis基礎(chǔ)--基本數(shù)據(jù)類(lèi)型
0 Redis 介紹 0.1 基礎(chǔ)知識(shí) 不僅僅是簡(jiǎn)單的key-value數(shù)據(jù)庫(kù)，更是一個(gè)in-memory data structure sto...
-
Intellij ide+sbt+Flink+scala Windows開(kāi)發(fā)環(huán)境配置(離線(xiàn)無(wú)網(wǎng)絡(luò))近期在無(wú)網(wǎng)絡(luò)環(huán)境內(nèi)網(wǎng) Window 環(huán)境配置 Flink開(kāi)發(fā)環(huán)境，很艱苦。由于準(zhǔn)備使用Scala，根據(jù)官網(wǎng)Flink推薦使用sbt 來(lái)進(jìn)行配置管...
-
微信公眾號(hào)python爬蟲(chóng)之總體概況這兩天看公眾號(hào)回顧之前的文章，有些文章發(fā)現(xiàn)已經(jīng)被刪甚至有些公眾號(hào)直接被屏蔽了。甚是可惜，想著可以做一個(gè)微信公眾號(hào)的爬蟲(chóng)來(lái)爬取文章保存到本地。 v...
-
Flink1.7.2 ZDH 集群 Standalone 模式獨(dú)立配置JDK1.8 小記
背景 實(shí)驗(yàn)室環(huán)境能夠申請(qǐng)的環(huán)境就是ZDH中興的R4B4集群，尚未能支持Flink組件。根據(jù)咨詢(xún)ZDH工程師，最新版本的應(yīng)該已經(jīng)有Flink組件了...
-
寫(xiě)給藝考生妹妹的高考動(dòng)員--關(guān)于文化課復(fù)習(xí)的一些見(jiàn)解（二）
接上文寫(xiě)給藝考生妹妹的高考動(dòng)員--關(guān)于文化課復(fù)習(xí)的一些見(jiàn)解（一） 數(shù)學(xué)嘛， 數(shù)學(xué)本來(lái)就是美的化身和代表！ 一行行公式凝聚的是人類(lèi)偉大的智慧結(jié)晶啊...
-
寫(xiě)給藝考生妹妹的高考動(dòng)員--關(guān)于文化課復(fù)習(xí)的一些見(jiàn)解（一）
前些日子跟藝考生妹妹的聊天，動(dòng)員吧，主要是談了談自己對(duì)高考各門(mén)課的見(jiàn)解，可能會(huì)有偏頗，可能沒(méi)有對(duì)癥下藥。也算高考動(dòng)員吧，第一篇主要包括：地理、歷...