Sink精品文章

• 

  Flume日志采集框架的使用

  ...夾、kafka等各種形式源數(shù)據(jù)，又可以將采集到的數(shù)據(jù)(下沉sink)輸出到HDFS、hbase、hive、kafka等眾多外部存儲(chǔ)系統(tǒng)中。 對(duì)于一般的采集需求，通過對(duì)flume的簡(jiǎn)單配置即可實(shí)現(xiàn)。 Flume針對(duì)特殊場(chǎng)景也具備良好的自定義擴(kuò)展能力，因此，f...

  laznrbfe 2019-07-24 10:57 評(píng)論0 收藏0
• 

  《從0到1學(xué)習(xí)Flink》—— Data Sink 介紹

  ... 介紹 講解了 Flink Data Source ，那么這里就來講講 Flink Data Sink 吧。 首先 Sink 的意思是： 大概可以猜到了吧！Data sink 有點(diǎn)把數(shù)據(jù)存儲(chǔ)下來（落庫(kù)）的意思。 如上圖，Source 就是數(shù)據(jù)的來源，中間的 Compute 其實(shí)就是 Flink 干的事情...

  thursday 2019-08-16 13:39 評(píng)論0 收藏0
• 

  k8s與審計(jì)-- 將clickhouse增加為 heapster sink

  ...要在查詢的時(shí)候做聚合。heapster支持諸多metrics輸出，稱為sink。目前支持的sink如下圖： 而我比較傾向于clickhouse數(shù)據(jù)庫(kù)，關(guān)于clickhouse，其實(shí)前面的文章介紹過很多了。所以本文主要講如何為heapster增加clickhouse sink。 代碼分析和實(shí)...

  tunny 2019-07-01 17:30 評(píng)論0 收藏0
• 

  k8s與審計(jì)-- 將clickhouse增加為 heapster sink

  ...要在查詢的時(shí)候做聚合。heapster支持諸多metrics輸出，稱為sink。目前支持的sink如下圖： 而我比較傾向于clickhouse數(shù)據(jù)庫(kù)，關(guān)于clickhouse，其實(shí)前面的文章介紹過很多了。所以本文主要講如何為heapster增加clickhouse sink。 代碼分析和實(shí)...

  edagarli 2019-07-01 16:47 評(píng)論0 收藏0
• 

  《從0到1學(xué)習(xí)Flink》—— 如何自定義 Data Sink ？

  前言 前篇文章 《從0到1學(xué)習(xí)Flink》—— Data Sink 介紹 介紹了 Flink Data Sink，也介紹了 Flink 自帶的 Sink，那么如何自定義自己的 Sink 呢？這篇文章將寫一個(gè) demo 教大家將從 Kafka Source 的數(shù)據(jù) Sink 到 MySQL 中去。 準(zhǔn)備工作 我們先來...

  NikoManiac 2019-08-16 13:40 評(píng)論0 收藏0
• 

  Kubernetes監(jiān)控之Heapster源碼分析

  ...ce=kubernetes:http://:8080?inClusterConfig=false&useServiceAccount=false --sink=influxdb:http://:8086 啟動(dòng)流程 從Heapster的啟動(dòng)流程開始分析其實(shí)現(xiàn)，前面做了簡(jiǎn)單的分析，可以帶著問題去看源碼會(huì)有更好的收獲。 main() 路徑： heapster/metrics/heapster.go...

  gclove 2019-07-01 16:31 評(píng)論0 收藏0
• 

  《從0到1學(xué)習(xí)Flink》—— Flink 寫入數(shù)據(jù)到 ElasticSearch

  ...(http://www.54tianzhisheng.cn/... 2、《從0到1學(xué)習(xí)Flink》—— Data Sink 介紹 其中包括了 Source 和 Sink 的，后面我也講了下如何自定義自己的 Source 和 Sink。 那么今天要做的事情是啥呢？就是介紹一下 Flink 自帶的 ElasticSearch Connector，我們今...

  W4n9Hu1 2019-08-16 14:33 評(píng)論0 收藏0