发简信
IP属地：山西
-
Flink集成iceberg在生产环境中的实践
背景及痛点[#%E8%83%8C%E6%99%AF%E5%8F%8A%E7%97%9B%E7%82%B9]业务背景[#%E4%B8%9A%E5%...
-
Flink集成数据湖之实时数据写入iceberg
背景 随着大数据处理结果的实时性要求越来越高，越来越多的大数据处理从离线转到了实时，其中以flink为主的实时计算在大数据处理中占有重要地位。 ...
-
深入解读flink sql cdc的使用以及源码分析
前言 flink消费cdc数据canal formatdebezium formatCanalJson反序列化源码解析 flink cdc co...
-
flink实战-使用自定义聚合函数统计网站TP指标
背景 自定义聚合函数 实例讲解 背景 在网站性能测试中，我们经常会选择 TP50、TP95 或者 TP99 等作为性能指标。接下来我们讲讲这些指...
-
flink教程-详解flink 1.11 中的CDC (Change Data Capture)
CDC简介 Canal CanalJson反序列化源码解析 CDC简介 CDC,Change Data Capture,变更数据获取的简称，使用...
-
详解flink中Look up维表的使用
背景 LookupableTableSource 实例讲解 源码解析JdbcTableSourceJdbcLookupFunction 背景 在...
-
聊聊flink 1.11 中的随机数据生成器- DataGen connector
使用 示例 源码解析创建TableSource数据生成器DataGeneratorDataGenTableSource 使用 在flink 1....
-
Flink源码分析之深度解读流式数据写入hive
前言 数据流处理hive基本信息获取流、批判断写入格式判断构造分区提交算子 详解StreamingFileWriter 简述StreamingF...
-
Flink教程-keyby 窗口数据倾斜的优化
在大数据处理领域，数据倾斜是一个非常常见的问题，今天我们就简单讲讲在flink中如何处理流式数据倾斜问题。 我们先来看一个可能产生数据倾斜的sq...