參考1參考2參考3參考4參考5 推送： 服務(wù)器給客戶端發(fā)送消息開發(fā)者通過第三方推送服務(wù)提供商將信息直接下發(fā)給需要的設(shè)備，第三方推送服務(wù)提供商與設(shè)備建立一條長連接通道，并且將消...
發(fā)簡信
IP屬地：北京
-
IM+推送+心跳機制 -
Flink1.11升級填坑
背景 現(xiàn)有集群版本是Flink 1.10.1，想要升級到社區(qū)最新的版本Flink 1.11.1. 踩坑過程 No hostname could be resolved for...
-
Kettle下載和安裝Kettle簡介：Kettle 是 PDI 以前的名稱，PDI 的全稱是Pentaho Data Integeration，Kettle 本意是水壺的意思，表達(dá)了數(shù)據(jù)流的含義...
-
python中defaultdict用法詳解
認(rèn)識defaultdict： 當(dāng)我使用普通的字典時，用法一般是dict={},添加元素的只需要dict[element] =value即，調(diào)用的時候也是如此，dict[ele...
-
Flink實戰(zhàn)—Flink SQL在Batch場景的Demo最近工作會用到Flink SQL，周末學(xué)習(xí)了一下，寫個demo做記錄，全部代碼請參考Github. 基于的Flink版本是1.9.1，使用的是java8開發(fā)。 本例是Flin...
-
Parquet 實踐和基本原理生成一個parquet文件 下載 編譯 運行 準(zhǔn)備csv文件 生成parquet文件 可見目錄下多了一個sample.parquet文件。這里沒有指定avsc格式的schem...
-
使用Flink完成流數(shù)據(jù)統(tǒng)計一、統(tǒng)計流程 所有流計算統(tǒng)計的流程都是：1、接入數(shù)據(jù)源2、進行多次數(shù)據(jù)轉(zhuǎn)換操作(過濾、拆分、聚合計算等)3、計算結(jié)果的存儲其中數(shù)據(jù)源可以是多個、數(shù)據(jù)轉(zhuǎn)換的節(jié)點處理完數(shù)據(jù)可以發(fā)...
-
聊聊flink如何兼容StormTopology
序 本文主要研究一下flink如何兼容StormTopology 實例 這里使用FlinkLocalCluster.getLocalCluster()來創(chuàng)建或獲取FlinkL...
