IP屬地：廣西
-
02-Flink流處理API
1.Environment 1.1 getExecutionEnvironment 創(chuàng)建一個執(zhí)行環(huán)境狈惫，表示當(dāng)前執(zhí)行程序的上下文邻薯。 如果程序是獨立...
-
01-Flink原理Flink運行時組件 作業(yè)管理器（JobManager）茄菊、資源管理器（ResourceManager）原环、任務(wù)管理器（TaskManager）痰娱， ...
-
Mysql數(shù)據(jù)通過Sqoop導(dǎo)入HDFS同步策略 ? 全量表：存儲完整的數(shù)據(jù)芽世。 ? 增量表：存儲新增加的數(shù)據(jù)斜脂。 ? 新增及變化表：存儲新增加的數(shù)據(jù)和變化的數(shù)據(jù)。 ?特殊表：只需要存儲一...
-
Flume
file->flume->kafka Flume組件選型 1）Source （1）Taildir Source相比Exec Source苗踪、Spo...
-
Kafka
Kafka 壓測 用Kafka官方自帶的腳本颠区，對Kafka進(jìn)行壓測。Kafka壓測時通铲，可以查看到哪個地方出現(xiàn)了瓶頸（CPU毕莱，內(nèi)存，網(wǎng)絡(luò)IO）颅夺。一...
-
hadoop模塊HDFS存儲多目錄 1.在DataNode節(jié)點增加磁盤并進(jìn)行掛載 2.在hdfs-site.xml文件中配置多目錄朋截，注意新掛載磁盤的訪問權(quán)限問題...