以下是個flink簡化的例子，看flink的代碼時有點疑問，env.execute(""),這句執(zhí)行任務(wù)，是怎么跟上面的數(shù)據(jù)流text的相關(guān)操作關(guān)聯(lián)起來的，看了半天源碼終于有...
發(fā)簡信
IP屬地：山西
-
flink源碼1- 對env.execute("")的疑問#streamgraph# -
聊一聊我喜歡的日本紀(jì)錄片之系列篇如果說，電視劇像鮮榨果汁，酸甜適中；電影像陳年老酒，百轉(zhuǎn)千回；紀(jì)錄片則是清香的茗茶，老少咸宜。為了滿足觀眾對未知世界的想象，電視劇和電影應(yīng)運而生，而追尋紀(jì)錄片存在的意...
-
hive分桶實踐
A表1億條記錄 B表1億條記錄， A表B表通過id字段關(guān)聯(lián)，直接關(guān)聯(lián)報錯，跑不動任務(wù)； 現(xiàn)在對A B表分別進行分桶，然后進行關(guān)聯(lián)： 主要用了hive的分桶原理，具體操作如下：...
-
-
當(dāng)我自律，一天24小時變成了48小時！
當(dāng)我自律，一天24小時變成了48小時！ 一 在朋友們眼里，我是個女超人般的存在。 每一天的行程滿滿的，一年365天不是在上班就是在上課，或者就是呆在健身房。 我的主業(yè)是一家國...
-
-
-
堅持晨跑四十天，我的生活發(fā)生了怎樣的改變今年10月中下旬，我給自己定了個小目標(biāo)，每天早上五點半起床跑步，堅持30天。到今天是第40天，寫篇文章做個總結(jié)。 之前的幾年一直斷斷續(xù)續(xù)跑步，基本上是送完孩子上學(xué)在小區(qū)跑大約...
-
移動APP用戶數(shù)據(jù)采集及分析案例
一個app要獲取用戶的日常點擊數(shù)據(jù)，各個事件的點擊及使用時長等數(shù)據(jù)，需要對app進行埋點，通過埋點數(shù)據(jù)上報，然后匯總統(tǒng)計app各業(yè)務(wù)數(shù)據(jù)，形成數(shù)據(jù)報告。 1埋點 定義埋點事件...
-
hbase優(yōu)化
1、內(nèi)存 年輕代年輕代最大值 java -Xmx256M -Xms256m -XX:NewSize=xxm -XX:MaxNewSize=xxm java -XX:+UseP...
-
datax使用說明
datax介紹 DataX 是阿里巴巴集團內(nèi)被廣泛使用的離線數(shù)據(jù)同步工具/平臺，實現(xiàn)包括 MySQL、Oracle、SqlServer、Postgre、HDFS、Hive、A...
-
CDH大數(shù)據(jù)安裝手冊--cdh安裝Cloudera Manager安裝 以下步驟在1號機(host1)上進行。 --安裝cm自帶oracle-j2sdk sudo yum install -y oracle-...
-
CDH大數(shù)據(jù)安裝手冊--基礎(chǔ)環(huán)境準(zhǔn)備CDH大數(shù)據(jù)安裝手冊 1.基礎(chǔ)環(huán)境準(zhǔn)備 操作系統(tǒng)要求CentOS7.4。 安裝介質(zhì)說明 除了系統(tǒng)自帶的OS源，我們會把其他安裝包整合到一個獨立的源。所有服務(wù)器都會使用該源，方...
-
99年小姐姐<br>文化傳媒公司簽約作者.<br>簡書青春專題推薦作者.<br>部分文章已設(shè)為私密，找我請至公眾號<br><br>???<br>個人公眾號：【云木說】<br>關(guān)注后回復(fù)：公眾號<br>可以獲取一份比百度還要詳細的新手教程<br><br>關(guān)注后回復(fù)：難度<br>可以獲取一份可靠的投稿渠道 <br>從簡單到難的都有,親自試水,不會被騙<br><br>轉(zhuǎn)載、約稿請至公眾號聯(lián)系<br>簡信較多一律不看.
-
