Sink

Sink精品文章

• 

  Flume日志采集框架的使用

  ...夹、kafka等各种形式源数据，又可以将采集到的数据(下沉sink)输出到HDFS、hbase、hive、kafka等众多外部存储系统中。 对于一般的采集需求，通过对flume的简单配置即可实现。 Flume针对特殊场景也具备良好的自定义扩展能力，因此，f...

  laznrbfe 2019-07-24 10:57 评论0 收藏0
• 

  《从0到1学习Flink》—— Data Sink 介绍

  ... 介绍 讲解了 Flink Data Source ，那么这里就来讲讲 Flink Data Sink 吧。 首先 Sink 的意思是： 大概可以猜到了吧！Data sink 有点把数据存储下来（落库）的意思。 如上图，Source 就是数据的来源，中间的 Compute 其实就是 Flink 干的事情...

  thursday 2019-08-16 13:39 评论0 收藏0
• 

  k8s与审计-- 将clickhouse增加为 heapster sink

  ...要在查询的时候做聚合。heapster支持诸多metrics输出，称为sink。目前支持的sink如下图： 而我比较倾向于clickhouse数据库，关于clickhouse，其实前面的文章介绍过很多了。所以本文主要讲如何为heapster增加clickhouse sink。 代码分析和实...

  tunny 2019-07-01 17:30 评论0 收藏0
• 

  k8s与审计-- 将clickhouse增加为 heapster sink

  ...要在查询的时候做聚合。heapster支持诸多metrics输出，称为sink。目前支持的sink如下图： 而我比较倾向于clickhouse数据库，关于clickhouse，其实前面的文章介绍过很多了。所以本文主要讲如何为heapster增加clickhouse sink。 代码分析和实...

  edagarli 2019-07-01 16:47 评论0 收藏0
• 

  《从0到1学习Flink》—— 如何自定义 Data Sink ？

  前言 前篇文章 《从0到1学习Flink》—— Data Sink 介绍 介绍了 Flink Data Sink，也介绍了 Flink 自带的 Sink，那么如何自定义自己的 Sink 呢？这篇文章将写一个 demo 教大家将从 Kafka Source 的数据 Sink 到 MySQL 中去。 准备工作 我们先来...

  NikoManiac 2019-08-16 13:40 评论0 收藏0
• 

  Kubernetes监控之Heapster源码分析

  ...ce=kubernetes:http://:8080?inClusterConfig=false&useServiceAccount=false --sink=influxdb:http://:8086 启动流程 从Heapster的启动流程开始分析其实现，前面做了简单的分析，可以带着问题去看源码会有更好的收获。 main() 路径： heapster/metrics/heapster.go...

  gclove 2019-07-01 16:31 评论0 收藏0
• 

  《从0到1学习Flink》—— Flink 写入数据到 ElasticSearch

  ...(http://www.54tianzhisheng.cn/... 2、《从0到1学习Flink》—— Data Sink 介绍 其中包括了 Source 和 Sink 的，后面我也讲了下如何自定义自己的 Source 和 Sink。 那么今天要做的事情是啥呢？就是介绍一下 Flink 自带的 ElasticSearch Connector，我们今...

  W4n9Hu1 2019-08-16 14:33 评论0 收藏0