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