IP屬地：四川
-
十七.Hadoop部分問題思考
1.關(guān)于切片的時(shí)候保證數(shù)據(jù)完整性的問題 MapReduce在進(jìn)行切片的時(shí)候有幾個(gè)參數(shù)，一個(gè)是最小切片大小(mapred.min.split.si...
-
關(guān)于IDEA配置文件和代碼的路徑Sources Root：告訴idea這個(gè)文件夾及其子文件夾中包含源代碼，是需要編譯構(gòu)建的一部分 Test Sources Root：測(cè)試源文件...
-
三.Flink集群搭建Flink可以選擇的部署方式有： Local、Standalone（資源利用率低）、Yarn、Mesos、Docker、Kubernetes、A...
-
二.Flink基本架構(gòu)
2.0 JobManager與TaskManager Flink運(yùn)行時(shí)包含了兩種類型的處理器： JobManager處理器：也稱之為Master...
-
一.Flink概述1.1 技術(shù)演變 流處理語(yǔ)義 At most once（最多一次）：每條數(shù)據(jù)記錄最多被處理一次，潛臺(tái)詞也表明數(shù)據(jù)會(huì)有丟失（沒被處理掉）的可能 A...
-
六.Kibana
Kibana是一個(gè)開源的分析和可視化平臺(tái)，設(shè)計(jì)用于和Elasticsearch一起工作。 你用Kibana來搜索，查看，并和存儲(chǔ)在Elastic...
-
五.Logstash5.1 Logstash簡(jiǎn)介 Logstash is a tool for managing events and logs. You can ...
-
四.IK分詞器
針對(duì)詞條查詢（TermQuery）,查看默認(rèn)中文分詞器的效果: [itstar@hadoop105 elasticsearch]$ curl -...
-
三.Java API操作
Elasticsearch的Java客戶端非常強(qiáng)大；它可以建立一個(gè)嵌入式實(shí)例并在必要時(shí)運(yùn)行管理任務(wù)。 運(yùn)行一個(gè)Java應(yīng)用程序和Elastics...