李小李可不能落后呀
IP屬地：四川
-
十七.Hadoop部分問題思考
1.關(guān)于切片的時候保證數(shù)據(jù)完整性的問題 MapReduce在進行切片的時候有幾個參數(shù)，一個是最小切片大小(mapred.min.split.size)，一個是最大切片大小(m...
-
關(guān)于IDEA配置文件和代碼的路徑Sources Root：告訴idea這個文件夾及其子文件夾中包含源代碼，是需要編譯構(gòu)建的一部分 Test Sources Root：測試源文件夾允許您將與測試相關(guān)的代碼與生...
-
-
三.Flink集群搭建Flink可以選擇的部署方式有： Local、Standalone（資源利用率低）、Yarn、Mesos、Docker、Kubernetes、AWS。 我們主要對Standa...
-
二.Flink基本架構(gòu)
2.0 JobManager與TaskManager Flink運行時包含了兩種類型的處理器： JobManager處理器：也稱之為Master，用于協(xié)調(diào)分布式執(zhí)行，它們用來...
-
-
五.Logstash5.1 Logstash簡介 Logstash is a tool for managing events and logs. You can use it to colle...
-
三.Java API操作
Elasticsearch的Java客戶端非常強大；它可以建立一個嵌入式實例并在必要時運行管理任務(wù)。 運行一個Java應(yīng)用程序和Elasticsearch時，有兩種操作模式可...
-
-
一.Elasticsearch概述1.1 什么是搜索 百度：我們比如說想找尋任何的信息的時候，就會上百度去搜索一下，比如說找一部自己喜歡的電影，或者說找一本喜歡的書，或者找一條感興趣的新聞（提到搜索的第一印象...
-
六.kafka Streams6.1 概述 6.1.1 Kafka Streams Kafka Streams。Apache Kafka開源項目的一個組成部分。是一個功能強大，易于使用的庫。用于在Kafk...
-
五.Kafka producer攔截器(interceptor)
5.1 攔截器原理 Producer攔截器(interceptor)是在Kafka 0.10版本被引入的，主要用于實現(xiàn)clients端的定制化控制邏輯。 對于producer...
-
四.KafkaAPI實戰(zhàn)
4.1 環(huán)境準(zhǔn)備 1）在eclipse中創(chuàng)建一個java工程 2）在工程的根目錄創(chuàng)建一個lib文件夾 3）解壓kafka安裝包，將安裝包libs目錄下的jar包拷貝到工程的l...
-
三.Kafka工作流程分析3.1 Kafka生產(chǎn)過程分析 3.1.1 寫入方式 producer采用推（push）模式將消息發(fā)布到broker，每條消息都被追加（append）到分區(qū)（patition...
-
二.Kafka集群部署2.1 環(huán)境準(zhǔn)備 2.1.1 集群規(guī)劃 bigdata11 bigdata12 bigdata13 zk zk zk kafka kaf...
-
一.Kafka基礎(chǔ)1.1 Kafka是什么 在流式計算中，Kafka一般用來緩存數(shù)據(jù)，Storm通過消費Kafka的數(shù)據(jù)進行計算。 1）Apache Kafka是一個開源消息系統(tǒng)，由Scala...
