首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
flink
相关资讯
热门
最新
代码人生
01-01 08:00
代码人生
Flink+Hudi 构架湖仓一体化解决方案
Flink+Hudi 构架湖仓一体化解决方案,本文转载自公众号【麒思妙想】,详细介绍了Flink+Hudi湖仓一体化方案的原型构建。主要内容为:Hudi新架构与湖仓一体最佳实践FlinkonHudiFlinkCDC2.0onHudi一、Hudi1.简介ApacheHudi(发音为“Hoodie”)在DFS的数据集上提供以下流原语插入更新(如何改变数据集?)增量拉取(如何获取变更的数据?)Hudi维
74
后端
01-01 08:00
后端
Flink学习:实践练习
练习的目标和范围 本次练习目前所包含的对于Apache Flink 的介绍内容忽略了大量(ultimately important)细节,因此仅能够满足让你可以开始编写可伸缩的流式ETL,数据分析以...
74
后端
01-01 08:00
后端
Flink源码阅读(七)--- Calcite 语法拓展
Calcite主要是做SQL解析、校验、优化等工作,比如Flink、Hive底层都是使用的calcite。本文内容是基于Flink 1.12来讲解。 首先从整体上对Calcite使用做个了解,Cal...
73
后端
01-01 08:00
后端
Flink-1.12(十一)Table API 和 Flink SQL
Table API 和 Flink SQL 是flink 对批处理和流处理,提供了统一的上层API。Table API 是一套内嵌在Java 和Scala 语言中的查询API,它允许以非常直观的方式...
72
后端
01-01 08:00
后端
Flink检查点机制与状态管理
1 检查点机制 1.1 CheckPoints 为了使 Flink 的状态具有良好的容错性,Flink 提供了检查点机制 (CheckPoints) 。通过检查点机制,Flink 定期在数据流上生成...
71
后端
01-01 08:00
后端
Flink集成iceberg在生产环境中的实践
背景及痛点[#%E8%83%8C%E6%99%AF%E5%8F%8A%E7%97%9B%E7%82%B9]业务背景[#%E4%B8%9A%E5%8A%A1%E8%83%8C%E6%99%AF]原架构...
71
后端
01-01 08:00
后端
Flink+Clickhouse在广投集团实时数仓的最佳实践
Flink+Clickhouse实时数仓在广投集团的最佳实践 一、业务背景 由于历史原因,大型集团企业往往多个帐套系统共存,包括国内知名ERP厂商浪潮、用友、金蝶、速达所提供的财务系统,集团财务共享...
71
代码人生
01-01 08:00
代码人生
Flink基础(128):FLINK-SQL语法 (22) DQL(14) OPERATIONS(11) Joins(5) 其他
Flink基础(128):FLINK-SQL语法 (22) DQL(14) OPERATIONS(11) Joins(5) 其他 Array Expansion(数组展开) 为给定数组中的每个元素返回新行 SELECT order_id, tagFROM Orders CROSS JOIN UNNEST(tags) AS t (tag) Table Function 连接表和 Table Func
71
后端
01-01 08:00
后端
Flink+Clickhouse实时数仓在广投集团的最佳实践
Flink+Clickhouse实时数仓在广投集团的最佳实践 一、业务背景 由于历史原因,大型集团企业往往多个帐套系统共存,包括国内知名ERP厂商浪潮、用友、金蝶、速达所提供的财务系统,集团财务共享...
70
后端
01-01 08:00
后端
Flink读取Kafka数据写入Hive
前言 本文针对数据库CDC(change data capture)场景设计,探讨基于Flink1.12最新版本提供的实时写入Hive的技术可行性,下面为本地IDEA程序案例可供参考。 一、整体思路...
70
«
1
2
...
7
8
9
10
11
12
13
14
15
»