IP屬地：新疆
-
02-Flink流處理API
1.Environment 1.1 getExecutionEnvironment 創(chuàng)建一個(gè)執(zhí)行環(huán)境，表示當(dāng)前執(zhí)行程序的上下文恨胚。 如果程序是獨(dú)立...
-
01-Flink原理Flink運(yùn)行時(shí)組件 作業(yè)管理器（JobManager）脚翘、資源管理器（ResourceManager）灼卢、任務(wù)管理器（TaskManager）， ...
-
Mysql數(shù)據(jù)通過Sqoop導(dǎo)入HDFS同步策略 ? 全量表：存儲(chǔ)完整的數(shù)據(jù)来农。 ? 增量表：存儲(chǔ)新增加的數(shù)據(jù)鞋真。 ? 新增及變化表：存儲(chǔ)新增加的數(shù)據(jù)和變化的數(shù)據(jù)。 ?特殊表：只需要存儲(chǔ)一...
-
Flume
file->flume->kafka Flume組件選型 1）Source （1）Taildir Source相比Exec Source沃于、Spo...
-
Kafka
Kafka 壓測(cè) 用Kafka官方自帶的腳本涩咖，對(duì)Kafka進(jìn)行壓測(cè)海诲。Kafka壓測(cè)時(shí)，可以查看到哪個(gè)地方出現(xiàn)了瓶頸（CPU檩互，內(nèi)存特幔，網(wǎng)絡(luò)IO）。一...
-
hadoop模塊HDFS存儲(chǔ)多目錄 1.在DataNode節(jié)點(diǎn)增加磁盤并進(jìn)行掛載 2.在hdfs-site.xml文件中配置多目錄闸昨，注意新掛載磁盤的訪問權(quán)限問題...