背景及痛点[#%E8%83%8C%E6%99%AF%E5%8F%8A%E7%97%9B%E7%82%B9]业务背景[#%E4%B8%9A%E5%8A%A1%E8%83%8C%...
发简信
IP属地：北京
-
Flink集成iceberg在生产环境中的实践
-
Flink集成数据湖之实时数据写入iceberg
背景 随着大数据处理结果的实时性要求越来越高，越来越多的大数据处理从离线转到了实时，其中以flink为主的实时计算在大数据处理中占有重要地位。 Flink消费kafka等实时...
-
深入解读flink sql cdc的使用以及源码分析
前言 flink消费cdc数据canal formatdebezium formatCanalJson反序列化源码解析 flink cdc connector背景mysql-...
-
flink实战-使用自定义聚合函数统计网站TP指标
背景 自定义聚合函数 实例讲解 背景 在网站性能测试中，我们经常会选择 TP50、TP95 或者 TP99 等作为性能指标。接下来我们讲讲这些指标的含义、以及在flink中如...
-
flink教程-详解flink 1.11 中的CDC (Change Data Capture)
CDC简介 Canal CanalJson反序列化源码解析 CDC简介 CDC,Change Data Capture,变更数据获取的简称，使用CDC我们可以从数据库中获取已...
-
聊聊flink 1.11 中的随机数据生成器- DataGen connector
使用 示例 源码解析创建TableSource数据生成器DataGeneratorDataGenTableSource 使用 在flink 1.11中，内置提供了一个Data...
-
Flink源码分析之深度解读流式数据写入hive
前言 数据流处理hive基本信息获取流、批判断写入格式判断构造分区提交算子 详解StreamingFileWriter 简述StreamingFileSink 分区信息提交提...
-
Flink教程-将流式数据写入redis
背景 实例讲解引入pom构造数据源构造redis配置实现RedisMapper 动态生成key 背景 redis作为一个高吞吐的存储系统，在生产中有着广泛的应用，今天我们主要...
-
flink modules详解之使用hive函数
modules概念 通过hive module使用hive函数内置函数自定义函数 sql 客户端的使用 原理分析和源码解析实现 modules概念 flink 提供了一个mo...