IP屬地：廣東
-
用flink算UV（UserVisit）數(shù)~即獨立訪客數(shù)思路：讀入數(shù)據(jù)時，用flatMap算子過濾出PV（即PageVisit）的一條條的數(shù)據(jù)，在process算子中，用set對用戶的id作去重，從而...
-
reduceopen方法只和并行度有關(guān)，并行度為幾，則open執(zhí)行幾次： 修改代碼，把并行度設(shè)為3，在reduce方法中輸出value1，value2的值：...
-
flink的鍵控流轉(zhuǎn)換算子輸入文件： min算子 輸入輸出之對照： Reduce算子 為了排除并行度帶來的影響，先把并行度設(shè)置為1： 如下兩圖，分別是 關(guān)鍵邏輯 和 輸出...
-
scala的伴生類和伴生對象Person帶有參構(gòu)造方法（上文系無參構(gòu)造方法）：
-
flink自定義數(shù)據(jù)源實體類： 測試代碼： 輸入輸出：
-
flink的local-cluster模式Flink中的Local-cluster(本地集群)模式,主要用于測試、學習，可幫助我們快速入門flink。 1）local-cluster模式...
-
flink的per-job模式啟動hdfs及yarn、zk后： 啟動yarn的per job： 在yarn的web頁面觀察： 輸入測試數(shù)據(jù)： 在flink的web頁面觀察：
-
hive on yarn的高可用啟動hdfs及yarn： 配置yarn，最多重啟RM 4次： 修改flink-conf.yaml ： 如下圖，kill了hadoop102的Jo...
-
PushConsumer和PullConsumer等Push 如下圖，讀到了很多歷史數(shù)據(jù)： 即時發(fā)2條消息： 即時收到2條消息： Pull DefaultLitePullConsumer