240 發(fā)簡(jiǎn)信
IP屬地：湖北
  • 02-Flink流處理API

    1.Environment 1.1 getExecutionEnvironment 創(chuàng)建一個(gè)執(zhí)行環(huán)境洒试，表示當(dāng)前執(zhí)行程序的上下文拣宏。 如果程序是獨(dú)立調(diào)用的，則此方法返回本地執(zhí)行環(huán)...

  • 120
    01-Flink原理

    Flink運(yùn)行時(shí)組件 作業(yè)管理器（JobManager）嚷狞、資源管理器（ResourceManager）、任務(wù)管理器（TaskManager）肩豁， 以及分發(fā)器（Dispatche...

  • 120
    Mysql數(shù)據(jù)通過(guò)Sqoop導(dǎo)入HDFS

    同步策略 ? 全量表：存儲(chǔ)完整的數(shù)據(jù)侍芝。 ? 增量表：存儲(chǔ)新增加的數(shù)據(jù)。 ? 新增及變化表：存儲(chǔ)新增加的數(shù)據(jù)和變化的數(shù)據(jù)比勉。 ?特殊表：只需要存儲(chǔ)一次劳较。 1.全量同步策略 2.增...

  • Flume

    file->flume->kafka Flume組件選型 1）Source （1）Taildir Source相比Exec Source、Spooling Directory...

  • 架構(gòu)圖

  • Kafka

    Kafka 壓測(cè) 用Kafka官方自帶的腳本浩聋，對(duì)Kafka進(jìn)行壓測(cè)观蜗。Kafka壓測(cè)時(shí)，可以查看到哪個(gè)地方出現(xiàn)了瓶頸（CPU衣洁，內(nèi)存墓捻，網(wǎng)絡(luò)IO）。一般都是網(wǎng)絡(luò)IO達(dá)到瓶頸坊夫。 1）...

  • 120
    hadoop模塊

    HDFS存儲(chǔ)多目錄 1.在DataNode節(jié)點(diǎn)增加磁盤(pán)并進(jìn)行掛載 2.在hdfs-site.xml文件中配置多目錄砖第，注意新掛載磁盤(pán)的訪問(wèn)權(quán)限問(wèn)題。 3.增加磁盤(pán)后环凿，保證每個(gè)目...

亚洲A日韩AV无卡,小受高潮白浆痉挛av免费观看,成人AV无码久久久久不卡网站,国产AV日韩精品