1. 摘要 PromQL (Prometheus Query Language) 是 Prometheus 自己开发的数据查询 DSL 语言,语言表现力非常丰富,内置函数很多...
1. 摘要 PromQL (Prometheus Query Language) 是 Prometheus 自己开发的数据查询 DSL 语言,语言表现力非常丰富,内置函数很多...
1.架构图 2.实现实例 2.1 通过flink cdc 的两张表 合并 成一张视图, 同时写入到数据湖(hudi) 中 同时写入到kafka 中 2.2 实现思路 2.3...
背景 某现场19年部署一套k8s集群,docker版本1.12 ,k8s版本1.8.6,现网k8s资源池规模,生产环境58台物理机,灰环境60台虚机(后来才知道用的一套k8s...
问题描述 按照网友提供的phoenix映射已存在的hbase表demo时,表映射正常,但是使用phoenix查询时,一直查询不到数据。 举个栗子: 1.hbaseshell插...
感谢分享,请问下分流下游事实表数据需要保证顺序,是不是只得写入kafka单个分区?谢谢~
Flink系列 - 实时数仓之FlinkCDC实现动态分流实战(十)自从Flink出了FlinkCDC之后,我们对数据库日志的采集就变得方便了许多了,除去了MaxWell、Cannel、OGG等第三方组件的繁琐配置,目前实现CDC有两种方...
自从Flink出了FlinkCDC之后,我们对数据库日志的采集就变得方便了许多了,除去了MaxWell、Cannel、OGG等第三方组件的繁琐配置,目前实现CDC有两种方...
环境 CDH-6.3.2Flink-1.12.2最后会补充说明Flink-1.13.1的使用方法 准备 在flink-1.12.2/lib目录需要放如下jar包 启动Flin...
Flink根据算子之间的依赖关系构建出Transformations并依次形成StreamGraph、JobGraph 、ExecutionGraph、 物理执行图。 Str...
数据血缘 数据血缘(data lineage)是数据治理(data governance)的重要组成部分,也是元数据管理、数据质量管理的有力工具。通俗地讲,数据血缘就是数据在...
不想看文章直接访问https://github.com/yuqi1129/schema/tree/master/mysql-protocol(Java版本的Mysql)、ht...
近期在看K8s的相关文档,看到通过YAML文件创建资源时,对不同资源应该怎么选择apiVersion不太理解,网上查找了一些相关的内容,记录如下: 首先,我们可以通过kube...
一、什么是SPI SPI ,全称为 Service Provider Interface,是一种服务发现机制。它通过在ClassPath路径下的META-INF/servic...
模板概述 基于 Antlr4 编译 hive 相关 xxx.g 文件生成对应的模板,如 hive 源码中: 编译完成生成对应 *.java 文件,Antlr4 详见: 解析流...